Commit87d8bd7

committed

Ensure all replication message info is available and correct via WalRcv

1 parentbe690e2 commit87d8bd7Copy full SHA for 87d8bd7

File tree

+11

-2

lines changed

+11

-2

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -218,7 +218,7 @@ WalReceiverMain(void)`
`218`	`218`	`startpoint=walrcv->receiveStart;`
`219`	`219`
`220`	`220`	`/* Initialise to a sanish value */`
`221`		`-walrcv->lastMsgSendTime=walrcv->lastMsgReceiptTime=GetCurrentTimestamp();`
	`221`	`+walrcv->lastMsgSendTime=walrcv->lastMsgReceiptTime=walrcv->latestWalEndTime=GetCurrentTimestamp();`
`222`	`222`
`223`	`223`	`SpinLockRelease(&walrcv->mutex);`
`224`	`224`
`@@ -749,6 +749,9 @@ ProcessWalSndrMessage(XLogRecPtr walEnd, TimestampTz sendTime)`
`749`	`749`
`750`	`750`	`/* Update shared-memory status */`
`751`	`751`	`SpinLockAcquire(&walrcv->mutex);`
	`752`	`+if (XLByteLT(walrcv->latestWalEnd,walEnd))`
	`753`	`+walrcv->latestWalEndTime=sendTime;`
	`754`	`+walrcv->latestWalEnd=walEnd;`
`752`	`755`	`walrcv->lastMsgSendTime=sendTime;`
`753`	`756`	`walrcv->lastMsgReceiptTime=lastMsgReceiptTime;`
`754`	`757`	`SpinLockRelease(&walrcv->mutex);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -260,7 +260,7 @@ GetReplicationApplyDelay(void)`
`260`	`260`
`261`	`261`	`replayPtr=GetXLogReplayRecPtr(NULL);`
`262`	`262`
`263`		`-if (XLByteLE(receivePtr,replayPtr))`
	`263`	`+if (XLByteEQ(receivePtr,replayPtr))`
`264`	`264`	`return0;`
`265`	`265`
`266`	`266`	`TimestampDifference(GetCurrentChunkReplayStartTime(),`

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,12 @@ typedef struct`
`83`	`83`	`TimestampTzlastMsgSendTime;`
`84`	`84`	`TimestampTzlastMsgReceiptTime;`
`85`	`85`
	`86`	`+/*`
	`87`	`+ * Latest reported end of WAL on the sender`
	`88`	`+ */`
	`89`	`+XLogRecPtrlatestWalEnd;`
	`90`	`+TimestampTzlatestWalEndTime;`
	`91`	`+`
`86`	`92`	`/*`
`87`	`93`	`* connection string; is used for walreceiver to connect with the primary.`
`88`	`94`	`*/`

Comments

(0)