Trace started callback invocation

knizhnik · kelvich · commit dde47c0a0869 · 2017-11-13T02:17:34.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -3082,6 +3082,7 @@ MtmReplicationStartedHook(struct PGLogicalStartedHookArgs* args)
 {
 	MtmLock(LW_EXCLUSIVE);	
 	MtmSenderStarted = 1;
+	elog(LOG, "Start %d senders and %d receivers from %d cluster status %s", Mtm->nSenders+1, Mtm->nReceivers, Mtm->nLiveNodes-1, MtmNodeStatusMnem[Mtm->status]);
 	if (++Mtm->nSenders == Mtm->nLiveNodes-1 && Mtm->nReceivers == Mtm->nLiveNodes-1 && Mtm->status == MTM_CONNECTED) { 
 		MtmSwitchClusterMode(MTM_ONLINE);
 	}

Original file line number	Diff line number	Diff line change
`@@ -3082,6 +3082,7 @@ MtmReplicationStartedHook(struct PGLogicalStartedHookArgs* args)`
`3082`	`3082`	`{`
`3083`	`3083`	`MtmLock(LW_EXCLUSIVE);`
`3084`	`3084`	`MtmSenderStarted = 1;`
	`3085`	`+ elog(LOG, "Start %d senders and %d receivers from %d cluster status %s", Mtm->nSenders+1, Mtm->nReceivers, Mtm->nLiveNodes-1, MtmNodeStatusMnem[Mtm->status]);`
`3085`	`3086`	`if (++Mtm->nSenders == Mtm->nLiveNodes-1 && Mtm->nReceivers == Mtm->nLiveNodes-1 && Mtm->status == MTM_CONNECTED) {`
`3086`	`3087`	`MtmSwitchClusterMode(MTM_ONLINE);`
`3087`	`3088`	`}`