Commit6a2cbe1

committed

Ensure all replication message info is available and correct via WalRcv

1 parent6f4b8a4 commit6a2cbe1Copy full SHA for 6a2cbe1

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
`@@ -219,7 +219,7 @@ WalReceiverMain(void)`
`219`	`219`	`startpoint=walrcv->receiveStart;`
`220`	`220`
`221`	`221`	`/* Initialise to a sanish value */`
`222`		`-walrcv->lastMsgSendTime=walrcv->lastMsgReceiptTime=GetCurrentTimestamp();`
	`222`	`+walrcv->lastMsgSendTime=walrcv->lastMsgReceiptTime=walrcv->latestWalEndTime=GetCurrentTimestamp();`
`223`	`223`
`224`	`224`	`SpinLockRelease(&walrcv->mutex);`
`225`	`225`
`@@ -759,6 +759,9 @@ ProcessWalSndrMessage(XLogRecPtr walEnd, TimestampTz sendTime)`
`759`	`759`
`760`	`760`	`/* Update shared-memory status */`
`761`	`761`	`SpinLockAcquire(&walrcv->mutex);`
	`762`	`+if (XLByteLT(walrcv->latestWalEnd,walEnd))`
	`763`	`+walrcv->latestWalEndTime=sendTime;`
	`764`	`+walrcv->latestWalEnd=walEnd;`
`762`	`765`	`walrcv->lastMsgSendTime=sendTime;`
`763`	`766`	`walrcv->lastMsgReceiptTime=lastMsgReceiptTime;`
`764`	`767`	`SpinLockRelease(&walrcv->mutex);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -261,7 +261,7 @@ GetReplicationApplyDelay(void)`
`261`	`261`
`262`	`262`	`replayPtr=GetXLogReplayRecPtr(NULL);`
`263`	`263`
`264`		`-if (XLByteLE(receivePtr,replayPtr))`
	`264`	`+if (XLByteEQ(receivePtr,replayPtr))`
`265`	`265`	`return0;`
`266`	`266`
`267`	`267`	`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)