PostgreSQL Source Code git master
Data Structures | Macros | Typedefs | Enumerations | Functions | Variables
walsender_private.h File Reference
#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"
Include dependency graph for walsender_private.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  WalSnd
 
struct  WalSndCtlData
 

Macros

#define SYNC_STANDBY_INIT   (1 << 0)
 
#define SYNC_STANDBY_DEFINED   (1 << 1)
 

Typedefs

typedef enum WalSndState WalSndState
 
typedef struct WalSnd WalSnd
 
typedef void * yyscan_t
 

Enumerations

enum  WalSndState {
  WALSNDSTATE_STARTUP = 0 , WALSNDSTATE_BACKUP , WALSNDSTATE_CATCHUP , WALSNDSTATE_STREAMING ,
  WALSNDSTATE_STOPPING
}
 

Functions

void WalSndSetState (WalSndState state)
 
int replication_yyparse (Node **replication_parse_result_p, yyscan_t yyscanner)
 
int replication_yylex (union YYSTYPE *yylval_param, yyscan_t yyscanner)
 
pg_noreturn void replication_yyerror (Node **replication_parse_result_p, yyscan_t yyscanner, const char *message)
 
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
 

Macro Definition Documentation

◆ SYNC_STANDBY_DEFINED

#define SYNC_STANDBY_DEFINED   (1 << 1)

Definition at line 132 of file walsender_private.h.

◆ SYNC_STANDBY_INIT

#define SYNC_STANDBY_INIT   (1 << 0)

Definition at line 125 of file walsender_private.h.

Typedef Documentation

◆ WalSnd

typedef struct WalSnd WalSnd

◆ WalSndState

typedef enum WalSndState WalSndState

◆ yyscan_t

typedef void* yyscan_t

Definition at line 144 of file walsender_private.h.

Enumeration Type Documentation

◆ WalSndState

enum WalSndState
Enumerator
WALSNDSTATE_STARTUP 
WALSNDSTATE_BACKUP 
WALSNDSTATE_CATCHUP 
WALSNDSTATE_STREAMING 
WALSNDSTATE_STOPPING 

Definition at line 24 of file walsender_private.h.

25{
26 WALSNDSTATE_STARTUP = 0,
27 WALSNDSTATE_BACKUP,
28 WALSNDSTATE_CATCHUP,
29 WALSNDSTATE_STREAMING,
30 WALSNDSTATE_STOPPING,
31} WalSndState;
WalSndState
WalSndState
Definition: walsender_private.h:25
WALSNDSTATE_STREAMING
@ WALSNDSTATE_STREAMING
Definition: walsender_private.h:29
WALSNDSTATE_BACKUP
@ WALSNDSTATE_BACKUP
Definition: walsender_private.h:27
WALSNDSTATE_CATCHUP
@ WALSNDSTATE_CATCHUP
Definition: walsender_private.h:28
WALSNDSTATE_STARTUP
@ WALSNDSTATE_STARTUP
Definition: walsender_private.h:26
WALSNDSTATE_STOPPING
@ WALSNDSTATE_STOPPING
Definition: walsender_private.h:30

Function Documentation

◆ replication_scanner_finish()

void replication_scanner_finish ( yyscan_t  yyscanner)

Definition at line 284 of file repl_scanner.l.

285{
286 pfree(yyextra);
287 yylex_destroy(yyscanner);
288}
pfree
void pfree(void *pointer)
Definition: mcxt.c:1594
yyextra
#define yyextra
Definition: scan.l:1118

References pfree(), and yyextra.

Referenced by exec_replication_command().

◆ replication_scanner_init()

void replication_scanner_init ( const char *  str,
yyscan_t *  yyscannerp 
)

Definition at line 268 of file repl_scanner.l.

269{
270 yyscan_t yyscanner;
271 struct replication_yy_extra_type *yyext = palloc0_object(struct replication_yy_extra_type);
272
273 if (yylex_init(yyscannerp) != 0)
274 elog(ERROR, "yylex_init() failed: %m");
275
276 yyscanner = *yyscannerp;
277
278 yyset_extra(yyext, yyscanner);
279
280 yy_scan_string(str, yyscanner);
281}
yyscan_t
void * yyscan_t
Definition: cubedata.h:65
ERROR
#define ERROR
Definition: elog.h:39
elog
#define elog(elevel,...)
Definition: elog.h:226
palloc0_object
#define palloc0_object(type)
Definition: fe_memutils.h:75
str
const char * str
Definition: hashfn_unstable.h:254
replication_yy_extra_type
Definition: repl_scanner.l:42

References elog, ERROR, palloc0_object, and str.

Referenced by exec_replication_command().

◆ replication_scanner_is_replication_command()

bool replication_scanner_is_replication_command ( yyscan_t  yyscanner)

Definition at line 299 of file repl_scanner.l.

300{
301 YYSTYPE dummy;
302 int first_token = replication_yylex(&dummy, yyscanner);
303
304 switch (first_token)
305 {
306 case K_IDENTIFY_SYSTEM:
307 case K_BASE_BACKUP:
308 case K_START_REPLICATION:
309 case K_CREATE_REPLICATION_SLOT:
310 case K_DROP_REPLICATION_SLOT:
311 case K_ALTER_REPLICATION_SLOT:
312 case K_READ_REPLICATION_SLOT:
313 case K_TIMELINE_HISTORY:
314 case K_UPLOAD_MANIFEST:
315 case K_SHOW:
316 /* Yes; push back the first token so we can parse later. */
317 yyextra->repl_pushed_back_token = first_token;
318 return true;
319 default:
320 /* Nope; we don't bother to push back the token. */
321 return false;
322 }
323}
YYSTYPE
int YYSTYPE
Definition: psqlscanslash.l:39
replication_yylex
int replication_yylex(union YYSTYPE *yylval_param, yyscan_t yyscanner)

References replication_yylex(), and yyextra.

Referenced by exec_replication_command().

◆ replication_yyerror()

pg_noreturn void replication_yyerror ( Node **  replication_parse_result_p,
yyscan_t  yyscanner,
const char *  message 
)

Definition at line 260 of file repl_scanner.l.

261{
262 ereport(ERROR,
263 (errcode(ERRCODE_SYNTAX_ERROR),
264 errmsg_internal("%s", message)));
265}
errmsg_internal
int errmsg_internal(const char *fmt,...)
Definition: elog.c:1170
errcode
int errcode(int sqlerrcode)
Definition: elog.c:863
ereport
#define ereport(elevel,...)
Definition: elog.h:150

References ereport, errcode(), errmsg_internal(), and ERROR.

◆ replication_yylex()

int replication_yylex ( union YYSTYPE *  yylval_param,
yyscan_t  yyscanner 
)

Referenced by replication_scanner_is_replication_command().

◆ replication_yyparse()

int replication_yyparse ( Node **  replication_parse_result_p,
yyscan_t  yyscanner 
)

Referenced by exec_replication_command().

◆ WalSndSetState()

void WalSndSetState ( WalSndState  state)

Definition at line 3936 of file walsender.c.

3937{
3938 WalSnd *walsnd = MyWalSnd;
3939
3940 Assert(am_walsender);
3941
3942 if (walsnd->state == state)
3943 return;
3944
3945 SpinLockAcquire(&walsnd->mutex);
3946 walsnd->state = state;
3947 SpinLockRelease(&walsnd->mutex);
3948}
Assert
Assert(PointerIsAligned(start, uint64))
SpinLockRelease
#define SpinLockRelease(lock)
Definition: spin.h:61
SpinLockAcquire
#define SpinLockAcquire(lock)
Definition: spin.h:59
WalSnd::mutex
slock_t mutex
Definition: walsender_private.h:71
WalSnd::state
WalSndState state
Definition: walsender_private.h:45
state
Definition: regguts.h:323
MyWalSnd
WalSnd * MyWalSnd
Definition: walsender.c:120
am_walsender
bool am_walsender
Definition: walsender.c:123

References am_walsender, Assert(), WalSnd::mutex, MyWalSnd, SpinLockAcquire, SpinLockRelease, and WalSnd::state.

Referenced by exec_replication_command(), SendBaseBackup(), StartLogicalReplication(), StartReplication(), WalSndErrorCleanup(), WalSndLoop(), and XLogSendPhysical().

Variable Documentation

◆ MyWalSnd

PGDLLIMPORT WalSnd* MyWalSnd
extern

Definition at line 120 of file walsender.c.

Referenced by exec_replication_command(), InitWalSenderSlot(), ProcessStandbyHSFeedbackMessage(), ProcessStandbyPSRequestMessage(), ProcessStandbyReplyMessage(), StartLogicalReplication(), StartReplication(), SyncRepGetCandidateStandbys(), SyncRepInitConfig(), SyncRepReleaseWaiters(), WalSndDone(), WalSndKill(), WalSndLoop(), WalSndSetState(), WalSndWait(), WalSndWaitForWal(), XLogSendLogical(), and XLogSendPhysical().

◆ WalSndCtl

PGDLLIMPORT WalSndCtlData* WalSndCtl
extern

Definition at line 117 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().