| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql10-server/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 407 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
408 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
409 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
444 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
445 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
446 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
447 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
763 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
891 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
975 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex);
407 MyWalSnd->sync_standby_priority = priority;
408 SpinLockRelease(&MyWalSnd->mutex);
443 if (MyWalSnd->sync_standby_priority == 0 ||
444 (MyWalSnd->state != WALSNDSTATE_STREAMING &&
445 MyWalSnd->state != WALSNDSTATE_STOPPING) ||
446 XLogRecPtrIsInvalid(MyWalSnd->flush))
762 stby->is_me = (walsnd == MyWalSnd);
890 if (am_sync != NULL && walsnd == MyWalSnd)
974 if (am_sync != NULL && walsnd == MyWalSnd)
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 405 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
406 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
407 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
442 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
443 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
444 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
445 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
761 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
889 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
973 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
407 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
408 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
443 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
444 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
445 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
446 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
762 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
890 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
974 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
407 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
408 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
443 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
444 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
445 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
446 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
762 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
890 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
974 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
407 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
408 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
443 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
444 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
445 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
446 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
762 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
890 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
974 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
407 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
408 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
443 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
444 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
445 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
446 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
762 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
890 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
974 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex);
407 MyWalSnd->sync_standby_priority = priority;
408 SpinLockRelease(&MyWalSnd->mutex);
443 if (MyWalSnd->sync_standby_priority == 0 ||
444 (MyWalSnd->state != WALSNDSTATE_STREAMING &&
445 MyWalSnd->state != WALSNDSTATE_STOPPING) ||
446 XLogRecPtrIsInvalid(MyWalSnd->flush))
762 stby->is_me = (walsnd == MyWalSnd);
890 if (am_sync != NULL && walsnd == MyWalSnd)
974 if (am_sync != NULL && walsnd == MyWalSnd)
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/replication/ |
| H A D | syncrep.c | 406 SpinLockAcquire(&MyWalSnd->mutex); in SyncRepInitConfig()
407 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
408 SpinLockRelease(&MyWalSnd->mutex); in SyncRepInitConfig()
443 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
444 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
445 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
446 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
762 stby->is_me = (walsnd == MyWalSnd); in SyncRepGetCandidateStandbys()
890 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysQuorum()
974 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbysPriority()
[all …]
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/replication/ |
| H A D | syncrep.c | 373 if (MyWalSnd->sync_standby_priority != priority) in SyncRepInitConfig()
376 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
411 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
412 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
413 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
414 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
442 application_name, MyWalSnd->sync_standby_priority))); in SyncRepReleaseWaiters()
620 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
631 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
690 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/replication/ |
| H A D | syncrep.c | 373 if (MyWalSnd->sync_standby_priority != priority) in SyncRepInitConfig()
376 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
411 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
412 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
413 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
414 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
442 application_name, MyWalSnd->sync_standby_priority))); in SyncRepReleaseWaiters()
620 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
631 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
690 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/replication/ |
| H A D | syncrep.c | 373 if (MyWalSnd->sync_standby_priority != priority) in SyncRepInitConfig()
376 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
411 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
412 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
413 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
414 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
442 application_name, MyWalSnd->sync_standby_priority))); in SyncRepReleaseWaiters()
620 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
631 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
690 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
|
| /dports/databases/postgresql96-client/postgresql-9.6.24/src/backend/replication/ |
| H A D | syncrep.c | 373 if (MyWalSnd->sync_standby_priority != priority) in SyncRepInitConfig()
376 MyWalSnd->sync_standby_priority = priority; in SyncRepInitConfig()
411 if (MyWalSnd->sync_standby_priority == 0 || in SyncRepReleaseWaiters()
412 (MyWalSnd->state != WALSNDSTATE_STREAMING && in SyncRepReleaseWaiters()
413 MyWalSnd->state != WALSNDSTATE_STOPPING) || in SyncRepReleaseWaiters()
414 XLogRecPtrIsInvalid(MyWalSnd->flush)) in SyncRepReleaseWaiters()
442 application_name, MyWalSnd->sync_standby_priority))); in SyncRepReleaseWaiters()
620 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
631 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
690 if (am_sync != NULL && walsnd == MyWalSnd) in SyncRepGetSyncStandbys()
|