#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

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 (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

Typedef Documentation

◆ WalSnd

typedef struct WalSnd WalSnd

◆ WalSndState

typedef enum WalSndState WalSndState

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.

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

Function Documentation

◆ replication_scanner_finish()

void replication_scanner_finish ( yyscan_t yyscanner )

Definition at line 284 of file repl_scanner.l.

{
    pfree(yyextra);
    yylex_destroy(yyscanner);
}

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.

{
    yyscan_t    yyscanner;
    struct replication_yy_extra_type *yyext = palloc0_object(struct replication_yy_extra_type);
 
    if (yylex_init(yyscannerp) != 0)
        elog(ERROR, "yylex_init() failed: %m");
 
    yyscanner = *yyscannerp;
 
    yyset_extra(yyext, yyscanner);
 
    yy_scan_string(str, yyscanner);
}

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.

{
    YYSTYPE     dummy;
    int         first_token = replication_yylex(&dummy, yyscanner);
 
    switch (first_token)
    {
        case K_IDENTIFY_SYSTEM:
        case K_BASE_BACKUP:
        case K_START_REPLICATION:
        case K_CREATE_REPLICATION_SLOT:
        case K_DROP_REPLICATION_SLOT:
        case K_ALTER_REPLICATION_SLOT:
        case K_READ_REPLICATION_SLOT:
        case K_TIMELINE_HISTORY:
        case K_UPLOAD_MANIFEST:
        case K_SHOW:
            /* Yes; push back the first token so we can parse later. */
            yyextra->repl_pushed_back_token = first_token;
            return true;
        default:
            /* Nope; we don't bother to push back the token. */
            return false;
    }
}

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.

{
    ereport(ERROR,
            (errcode(ERRCODE_SYNTAX_ERROR),
             errmsg_internal("%s", message)));
}

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 3782 of file walsender.c.

{
    WalSnd     *walsnd = MyWalSnd;
 
    Assert(am_walsender);
 
    if (walsnd->state == state)
        return;
 
    SpinLockAcquire(&walsnd->mutex);
    walsnd->state = state;
    SpinLockRelease(&walsnd->mutex);
}