8000 Using WalSndCtl's lsn values · pct960/postgres@658c729 · GitHub
[go: up one dir, main page]
Skip to content

Commit 658c729

Browse files
pct960pct960
committed
Using WalSndCtl's lsn values
1 parent 4b7f415 commit 658c729

File tree

1 file changed

+6
-6
lines changed
  • src/backend/access/transam

1 file changed

+6
-6
lines changed

‎src/backend/access/transam/xact.c

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1360,11 +1360,11 @@ RecordTransactionCommit(void)
13601360
{
13611361
XLogRecPtr XLogMaxLSN = XLogGetMaxLSN(NULL);
13621362
//XLogRecPtr walSndAppliedLSN = SyncRepGetWalSndLSN();
1363-
XLogRecPtr RecentFlushPtr = InvalidXLogRecPtr;
1364-
if (!RecoveryInProgress())
1365-
RecentFlushPtr = GetFlushRecPtr(NULL);
1366-
else
1367-
RecentFlushPtr = GetXLogReplayRecPtr(NULL);
1363+
//XLogRecPtr RecentFlushPtr = InvalidXLogRecPtr;
1364+
//if (!RecoveryInProgress())
1365+
// RecentFlushPtr = GetFlushRecPtr(NULL);
1366+
//else
1367+
// RecentFlushPtr = GetXLogReplayRecPtr(NULL);
13681368

13691369
//LWLockAcquire(SyncRepLock, LW_EXCLUSIVE);
13701370
//PGPROC *proc;
@@ -1380,7 +1380,7 @@ RecordTransactionCommit(void)
13801380
//elog(INFO, "Queue empty? = (%d)", SHMQueueEmpty(&(WalSndCtl->SyncRepQueue[Min(synchronous_commit, SYNC_REP_WAIT_FLUSH)])));
13811381
//LWLockRelease(SyncRepLock);
13821382

1383-
XLogRecPtr remoteFlushLSN = ((volatile WalSndCtlData *) WalSndCtl)->lsn[Min(synchronous_commit, SYNC_REP_WAIT_FLUSH)];
1383+
XLogRecPtr remoteFlushLSN = ((volatile WalSndCtlData *) WalSndCtl)->lsn[Min(synchronous_commit, SYNC_REP_WAIT_APPLY)];
13841384
//elog(INFO, "once again, lsn = (%d)", remoteFlushLSN);
13851385
//elog(INFO, "maxlsn = (%d), remotelsn = (%d)", XLogMaxLSN, remoteFlushLSN);
13861386

0 commit comments

Comments
 (0)
0