PostgreSQL Source Code git master
|
#include "access/xlog.h"
#include "lib/ilist.h"
#include "nodes/nodes.h"
#include "nodes/replnodes.h"
#include "replication/syncrep.h"
#include "storage/condition_variable.h"
#include "storage/shmem.h"
#include "storage/spin.h"
Go to the source code of this file.
Data Structures | |
struct | WalSnd |
struct | WalSndCtlData |
Typedefs | |
typedef enum WalSndState | WalSndState |
typedef struct WalSnd | WalSnd |
Enumerations | |
enum | WalSndState { WALSNDSTATE_STARTUP = 0 , WALSNDSTATE_BACKUP , WALSNDSTATE_CATCHUP , WALSNDSTATE_STREAMING , WALSNDSTATE_STOPPING } |
Functions | |
void | WalSndSetState (WalSndState state) |
int | replication_yyparse (yyscan_t yyscanner) |
int | replication_yylex (union YYSTYPE *yylval_param, yyscan_t yyscanner) |
void | replication_yyerror (yyscan_t yyscanner, const char *message) pg_attribute_noreturn() |
void | replication_scanner_init (const char *str, yyscan_t *yyscannerp) |
void | replication_scanner_finish (yyscan_t yyscanner) |
bool | replication_scanner_is_replication_command (yyscan_t yyscanner) |
Variables | |
PGDLLIMPORT WalSnd * | MyWalSnd |
PGDLLIMPORT WalSndCtlData * | WalSndCtl |
PGDLLIMPORT Node * | replication_parse_result |
typedef enum WalSndState WalSndState |
enum WalSndState |
Enumerator | |
---|---|
WALSNDSTATE_STARTUP | |
WALSNDSTATE_BACKUP | |
WALSNDSTATE_CATCHUP | |
WALSNDSTATE_STREAMING | |
WALSNDSTATE_STOPPING |
Definition at line 24 of file walsender_private.h.
void replication_scanner_finish | ( | yyscan_t | yyscanner | ) |
Definition at line 280 of file repl_scanner.l.
References pfree(), yyextra, and yyscanner.
Referenced by exec_replication_command().
void replication_scanner_init | ( | const char * | str, |
yyscan_t * | yyscannerp | ||
) |
Definition at line 264 of file repl_scanner.l.
References elog, ERROR, palloc0_object, str, and yyscanner.
Referenced by exec_replication_command().
bool replication_scanner_is_replication_command | ( | yyscan_t | yyscanner | ) |
Definition at line 295 of file repl_scanner.l.
References replication_yylex(), yyextra, and yyscanner.
Referenced by exec_replication_command().
void replication_yyerror | ( | yyscan_t | yyscanner, |
const char * | message | ||
) |
Definition at line 256 of file repl_scanner.l.
References ereport, errcode(), errmsg_internal(), and ERROR.
Referenced by replication_scanner_is_replication_command().
int replication_yyparse | ( | yyscan_t | yyscanner | ) |
Referenced by exec_replication_command().
void WalSndSetState | ( | WalSndState | state | ) |
Definition at line 3782 of file walsender.c.
References am_walsender, Assert, WalSnd::mutex, MyWalSnd, SpinLockAcquire, SpinLockRelease, and WalSnd::state.
Referenced by exec_replication_command(), SendBaseBackup(), StartLogicalReplication(), StartReplication(), WalSndErrorCleanup(), WalSndLoop(), and XLogSendPhysical().
|
extern |
Definition at line 112 of file walsender.c.
Referenced by exec_replication_command(), InitWalSenderSlot(), ProcessStandbyHSFeedbackMessage(), ProcessStandbyReplyMessage(), StartLogicalReplication(), StartReplication(), SyncRepGetCandidateStandbys(), SyncRepInitConfig(), SyncRepReleaseWaiters(), WalSndDone(), WalSndKill(), WalSndLoop(), WalSndSetState(), WalSndWait(), WalSndWaitForWal(), XLogSendLogical(), and XLogSendPhysical().
|
extern |
Referenced by exec_replication_command().
|
extern |
Definition at line 109 of file walsender.c.
Referenced by InitWalSenderSlot(), pg_stat_get_wal_senders(), PhysicalWakeupLogicalWalSnd(), SyncRepGetCandidateStandbys(), SyncRepQueueInsert(), SyncRepReleaseWaiters(), SyncRepUpdateSyncStandbysDefined(), SyncRepWaitForLSN(), SyncRepWakeQueue(), WaitForStandbyConfirmation(), WalSndInitStopping(), WalSndRqstFileReload(), WalSndShmemInit(), WalSndUpdateProgress(), WalSndWait(), WalSndWaitStopping(), and WalSndWakeup().