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{
WalSndState
@ WALSNDSTATE_STREAMING
@ WALSNDSTATE_BACKUP
@ WALSNDSTATE_CATCHUP
@ WALSNDSTATE_STARTUP
@ WALSNDSTATE_STOPPING

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}
void pfree(void *pointer)
Definition: mcxt.c:1594
#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;
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}
void * yyscan_t
Definition: cubedata.h:65
#define ERROR
Definition: elog.h:39
#define elog(elevel,...)
Definition: elog.h:226
#define palloc0_object(type)
Definition: fe_memutils.h:75
const char * str
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}
int YYSTYPE
Definition: psqlscanslash.l:39
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{
263 (errcode(ERRCODE_SYNTAX_ERROR),
264 errmsg_internal("%s", message)));
265}
int errmsg_internal(const char *fmt,...)
Definition: elog.c:1161
int errcode(int sqlerrcode)
Definition: elog.c:854
#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 3922 of file walsender.c.

3923{
3924 WalSnd *walsnd = MyWalSnd;
3925
3927
3928 if (walsnd->state == state)
3929 return;
3930
3931 SpinLockAcquire(&walsnd->mutex);
3932 walsnd->state = state;
3933 SpinLockRelease(&walsnd->mutex);
3934}
Assert(PointerIsAligned(start, uint64))
#define SpinLockRelease(lock)
Definition: spin.h:61
#define SpinLockAcquire(lock)
Definition: spin.h:59
slock_t mutex
WalSndState state
Definition: regguts.h:323
WalSnd * MyWalSnd
Definition: walsender.c:120
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

◆ WalSndCtl

AltStyle によって変換されたページ (->オリジナル) /