database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add fix

Browse Source
This commit is contained in:
james
2024-09-23 16:42:49 +08:00
parent f502278bd6
commit 7fbf409ca3
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/gausskernel/storage/replication/walreceiver.cpp
View File

@ -2700,6 +2700,7 @@ Datum gs_get_recv_locations(PG_FUNCTION_ARGS)
XLogRecPtr rcvRedo;
XLogRecPtr rcvWrite;
XLogRecPtr lastRplReadLsn;
XLogRecPtr rcvFlush;
XLogRecPtr rcvReceived;
XLogRecPtr localMaxLSN;
@ -2764,7 +2765,10 @@ Datum gs_get_recv_locations(PG_FUNCTION_ARGS)
securec_check(rc, "\0", "\0");
} else {
rcvRedo = GetXLogReplayRecPtr(NULL, NULL);
rcvRedo = GetXLogReplayRecPtr(NULL, &lastRplReadLsn);
if (XLByteEQ(lastRplReadLsn, rcvReceived)) {
rcvRedo = rcvReceived;
}
/* receiver_received_location */
if (rcvReceived == 0) {
localMaxLSN = FindMaxLSN(t_thrd.proc_cxt.DataDir, maxLsnMsg, XLOG_READER_MAX_MSGLENTH, &localMaxLsnCrc,