Commite6d3936

authored and

committed

Push responses to WAL sender

1 parentdc3e86c commite6d3936Copy full SHA for e6d3936

File tree

-2

lines changed

-2

lines changed

Lines changed: 8 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,7 @@ feTimestampDifference(int64 start_time, int64 stop_time,`
`193`	`193`
`194`	`194`	`staticcharconst*constMtmReplicationModeName[]=`
`195`	`195`	`{`
`196`		`-"exit",`
	`196`	`+"exit",`
`197`	`197`	`"recovered",/* recovery of node is completed so drop old slot and restart replication from the current position in WAL */`
`198`	`198`	`"recovery",/* perform recorvery of the node by applying all data from theslot from specified point */`
`199`	`199`	`"normal"/* normal mode: use existed slot or create new one and start receiving data from it from the specified position */`
`@@ -568,7 +568,13 @@ pglogical_receiver_main(Datum main_arg)`
`568`	`568`	`timeoutptr=&timeout;`
`569`	`569`
`570`	`570`	`r=select(PQsocket(conn)+1,&input_mask,NULL,NULL,timeoutptr);`
`571`		`-if (r==0\|\| (r<0&&errno==EINTR))`
	`571`	`+if (r==0)`
	`572`	`+{`
	`573`	`+int64now=feGetCurrentTimestamp();`
	`574`	`+sendFeedback(conn,now,nodeId);`
	`575`	`+continue;`
	`576`	`+}`
	`577`	`+elseif (r<0&&errno==EINTR)`
`572`	`578`	`{`
`573`	`579`	`/*`
`574`	`580`	`* Got a timeout or signal. Continue the loop and either`

Comments

(0)