database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-01 01:04:50 +03:00
Code

Code cleanup in SyncRepWaitForLSN()

Browse Source 
Commit 14e8803f1 removed LWLocks when accessing MyProc->syncRepState
but didn't clean up the surrounding code and comments.

Cleanup and backpatch to 9.5, to keep code similar.

Julien Rouhaud, improved by suggestion from Michael Paquier,
implemented trivially by myself.
This commit is contained in:
Simon Riggs 2016-08-12 12:43:45 +01:00
parent 6e75559ea9
commit e05f6f75db
1 changed files with 5 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/backend/replication/syncrep.c
View File

@ -189,24 +189,16 @@ SyncRepWaitForLSN(XLogRecPtr lsn, bool commit)
*/ */
for (;;) for (;;)
{ {
int syncRepState;
/* Must reset the latch before testing state. */ /* Must reset the latch before testing state. */
ResetLatch(MyLatch); ResetLatch(MyLatch);
/* /*
* Try checking the state without the lock first. There's no * Acquiring the lock is not needed, the latch ensures proper barriers.
* guarantee that we'll read the most up-to-date value, so if it looks * If it looks like we're done, we must really be done, because once
* like we're still waiting, recheck while holding the lock. But if * walsender changes the state to SYNC_REP_WAIT_COMPLETE, it will never
* it looks like we're done, we must really be done, because once * update it again, so we can't be seeing a stale value in that case.
* walsender changes the state to SYNC_REP_WAIT_COMPLETE, it will
* never update it again, so we can't be seeing a stale value in that
* case.
*/ */
syncRepState = MyProc->syncRepState; if (MyProc->syncRepState == SYNC_REP_WAIT_COMPLETE)
if (syncRepState == SYNC_REP_WAITING)
syncRepState = MyProc->syncRepState;
if (syncRepState == SYNC_REP_WAIT_COMPLETE)
break; break;
/* /*