Skip to content

Commit c380f7b

Browse files
committed
better logging of parallel-safe message
1 parent 7c402b4 commit c380f7b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

Diff for: src/pglogical_apply.c

+4-1
Original file line numberDiff line numberDiff line change
@@ -671,7 +671,7 @@ process_remote_message(StringInfo s, MtmReceiverContext *receiver_ctx)
671671
{
672672
int64 session_id = 0;
673673

674-
mtm_log(MtmApplyMessage, "Executing parallel-safe message from %d: %s",
674+
mtm_log(MtmApplyMessage, "Processing parallel-safe message from %d: %s",
675675
receiver_ctx->node_id, messageBody);
676676

677677
sscanf(messageBody, INT64_FORMAT, &session_id);
@@ -686,6 +686,9 @@ process_remote_message(StringInfo s, MtmReceiverContext *receiver_ctx)
686686
Assert(receiver_ctx->node_id > 0);
687687
Assert(receiver_ctx->node_id == MtmReplicationNodeId);
688688

689+
mtm_log(MtmApplyMessage, "Executing parallel-safe message from %d: %s",
690+
receiver_ctx->node_id, messageBody);
691+
689692
receiver_ctx->parallel_allowed = true;
690693
MtmStateProcessNeighborEvent(MtmReplicationNodeId, MTM_NEIGHBOR_WAL_RECEIVER_START, false);
691694
}

0 commit comments

Comments
 (0)