Commit2b327b6

authored and

committed

Push responses to WAL sender

1 parente6d3936 commit2b327b6Copy full SHA for 2b327b6

File tree

-7

lines changed

-7

lines changed

Lines changed: 8 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -2484,13 +2484,14 @@ void MtmUpdateLsnMapping(int node_id, XLogRecPtr end_lsn)`
`2484`	`2484`	`XLogRecPtrlocal_flush=GetFlushRecPtr();`
`2485`	`2485`	`MemoryContextold_context=MemoryContextSwitchTo(TopMemoryContext);`
`2486`	`2486`
`2487`		`-/* Track commit lsn */`
`2488`		`-flushpos= (MtmFlushPosition*)palloc(sizeof(MtmFlushPosition));`
`2489`		`-flushpos->node_id=node_id;`
`2490`		`-flushpos->local_end=XactLastCommitEnd;`
`2491`		`-flushpos->remote_end=end_lsn;`
`2492`		`-dlist_push_tail(&MtmLsnMapping,&flushpos->node);`
`2493`		`-`
	`2487`	`+if (end_lsn!=InvalidXLogRecPtr) {`
	`2488`	`+/* Track commit lsn */`
	`2489`	`+flushpos= (MtmFlushPosition*)palloc(sizeof(MtmFlushPosition));`
	`2490`	`+flushpos->node_id=node_id;`
	`2491`	`+flushpos->local_end=XactLastCommitEnd;`
	`2492`	`+flushpos->remote_end=end_lsn;`
	`2493`	`+dlist_push_tail(&MtmLsnMapping,&flushpos->node);`
	`2494`	`+}`
`2494`	`2495`	`MtmLock(LW_EXCLUSIVE);`
`2495`	`2496`	`dlist_foreach_modify(iter,&MtmLsnMapping)`
`2496`	`2497`	`{`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -571,6 +571,7 @@ pglogical_receiver_main(Datum main_arg)`
`571`	`571`	`if (r==0)`
`572`	`572`	`{`
`573`	`573`	`int64now=feGetCurrentTimestamp();`
	`574`	`+MtmUpdateLsnMapping(nodeId,InvalidXLogRecPtr);`
`574`	`575`	`sendFeedback(conn,now,nodeId);`
`575`	`576`	`continue;`
`576`	`577`	`}`

Comments

(0)