19 #define SyncRepRequested() \
20 (max_wal_senders > 0 && synchronous_commit > SYNCHRONOUS_COMMIT_LOCAL_FLUSH)
23 #define SYNC_REP_NO_WAIT (-1)
24 #define SYNC_REP_WAIT_WRITE 0
25 #define SYNC_REP_WAIT_FLUSH 1
26 #define SYNC_REP_WAIT_APPLY 2
28 #define NUM_SYNC_REP_WAIT_MODE 3
31 #define SYNC_REP_NOT_WAITING 0
32 #define SYNC_REP_WAITING 1
33 #define SYNC_REP_WAIT_COMPLETE 2
36 #define SYNC_REP_PRIORITY 0
37 #define SYNC_REP_QUORUM 1
#define FLEXIBLE_ARRAY_MEMBER
static rewind_source * source
char member_names[FLEXIBLE_ARRAY_MEMBER]
int sync_standby_priority
void SyncRepInitConfig(void)
void SyncRepWaitForLSN(XLogRecPtr lsn, bool commit)
void assign_synchronous_commit(int newval, void *extra)
struct SyncRepConfigData SyncRepConfigData
void assign_synchronous_standby_names(const char *newval, void *extra)
void syncrep_scanner_finish(void)
struct SyncRepStandbyData SyncRepStandbyData
void syncrep_scanner_init(const char *query_string)
int SyncRepGetCandidateStandbys(SyncRepStandbyData **standbys)
void syncrep_yyerror(const char *str)
void SyncRepReleaseWaiters(void)
PGDLLIMPORT SyncRepConfigData * SyncRepConfig
PGDLLIMPORT char * SyncRepStandbyNames
void SyncRepUpdateSyncStandbysDefined(void)
int syncrep_yyparse(void)
PGDLLIMPORT SyncRepConfigData * syncrep_parse_result
PGDLLIMPORT char * syncrep_parse_error_msg
bool check_synchronous_standby_names(char **newval, void **extra, GucSource source)
void SyncRepCleanupAtProcExit(void)