|
|
|
@ -364,7 +364,7 @@ SyncRepInitConfig(void) |
|
|
|
* Update the LSNs on each queue based upon our latest state. This |
|
|
|
* Update the LSNs on each queue based upon our latest state. This |
|
|
|
* implements a simple policy of first-valid-standby-releases-waiter. |
|
|
|
* implements a simple policy of first-valid-standby-releases-waiter. |
|
|
|
* |
|
|
|
* |
|
|
|
* Other policies are possible, which would change what we do here and what |
|
|
|
* Other policies are possible, which would change what we do here and |
|
|
|
* perhaps also which information we store as well. |
|
|
|
* perhaps also which information we store as well. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
void |
|
|
|
void |
|
|
|
@ -379,9 +379,9 @@ SyncRepReleaseWaiters(void) |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* If this WALSender is serving a standby that is not on the list of |
|
|
|
* If this WALSender is serving a standby that is not on the list of |
|
|
|
* potential standbys then we have nothing to do. If we are still starting |
|
|
|
* potential sync standbys then we have nothing to do. If we are still |
|
|
|
* up, still running base backup or the current flush position is still |
|
|
|
* starting up, still running base backup or the current flush position |
|
|
|
* invalid, then leave quickly also. |
|
|
|
* is still invalid, then leave quickly also. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
if (MyWalSnd->sync_standby_priority == 0 || |
|
|
|
if (MyWalSnd->sync_standby_priority == 0 || |
|
|
|
MyWalSnd->state < WALSNDSTATE_STREAMING || |
|
|
|
MyWalSnd->state < WALSNDSTATE_STREAMING || |
|
|
|
|