Commit65b18ec

committed

Trace started callback invocation

1 parentae341ef commit65b18ecCopy full SHA for 65b18ec

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 0 deletions

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`	`}`

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -451,8 +451,10 @@ DecodingContextFindStartpoint(LogicalDecodingContext *ctx)`
`451`	`451`	`ctx->slot->data.confirmed_flush=ctx->reader->EndRecPtr;`
`452`	`452`
`453`	`453`	`old_context=MemoryContextSwitchTo(ctx->context);`
`454`		`-if (ctx->callbacks.started_cb!=NULL)`
	`454`	`+if (ctx->callbacks.started_cb!=NULL) {`
	`455`	`+elog(LOG,"Call started callback");`
`455`	`456`	`started_cb_wrapper(ctx);`
	`457`	`+}`
`456`	`458`	`MemoryContextSwitchTo(old_context);`
`457`	`459`	`}`
`458`	`460`
`@@ -577,7 +579,7 @@ started_cb_wrapper(LogicalDecodingContext *ctx)`
`577`	`579`
`578`	`580`	`/* Push callback + info on the error context stack */`
`579`	`581`	`state.ctx=ctx;`
`580`		`-state.callback_name="startup";`
	`582`	`+state.callback_name="started";`
`581`	`583`	`state.report_location=InvalidXLogRecPtr;`
`582`	`584`	`errcallback.callback=output_plugin_error_callback;`
`583`	`585`	`errcallback.arg= (void*)&state;`

Comments

(0)