Trace started callback invocation

Author: knizhnik

contrib/mmts/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);
 	}

src/backend/replication/logical/logical.c

@@ -451,8 +451,10 @@ DecodingContextFindStartpoint(LogicalDecodingContext *ctx)
 	ctx->slot->data.confirmed_flush = ctx->reader->EndRecPtr;
 
 	old_context = MemoryContextSwitchTo(ctx->context);
-	if (ctx->callbacks.started_cb != NULL)
+	if (ctx->callbacks.started_cb != NULL) {
+		elog(LOG, "Call started callback");
 		started_cb_wrapper(ctx);
+	}
 	MemoryContextSwitchTo(old_context);
 }
 
@@ -577,7 +579,7 @@ started_cb_wrapper(LogicalDecodingContext *ctx)
 
 	/* Push callback + info on the error context stack */
 	state.ctx = ctx;
-	state.callback_name = "startup";
+	state.callback_name = "started";
 	state.report_location = InvalidXLogRecPtr;
 	errcallback.callback = output_plugin_error_callback;
 	errcallback.arg = (void *) &state;