Commit965d1fe

committed

fix walsender merge issues

1 parentfaab99b commit965d1feCopy full SHA for 965d1fe

File tree

+10

-1

lines changed

+10

-1

lines changed

Lines changed: 10 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -2475,8 +2475,17 @@ XLogSendLogical(void)`
`2475`	`2475`	`* If the record we just wanted read is at or beyond the flushed`
`2476`	`2476`	`* point, then we're caught up.`
`2477`	`2477`	`*/`
`2478`		`-if (logical_decoding_ctx->reader->EndRecPtr >=GetFlushRecPtr()) {`
	`2478`	`+if (logical_decoding_ctx->reader->EndRecPtr >=GetFlushRecPtr())`
	`2479`	`+{`
`2479`	`2480`	`WalSndCaughtUp= true;`
	`2481`	`+`
	`2482`	`+/*`
	`2483`	`+ * Have WalSndLoop() terminate the connection in an orderly`
	`2484`	`+ * manner, after writing out all the pending data.`
	`2485`	`+ */`
	`2486`	`+if (got_STOPPING)`
	`2487`	`+got_SIGUSR2= true;`
	`2488`	`+`
`2480`	`2489`	`LogicalDecodingCaughtUp(logical_decoding_ctx);`
`2481`	`2490`	`}`
`2482`	`2491`	`}`

Comments

(0)