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.

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

Function Documentation

replication_scanner_finish()

void replication_scanner_finish ( yyscan_t  yyscanner )

extern

Definition at line 284 of file repl_scanner.l.

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

References fb(), pfree(), and yyextra.

Referenced by exec_replication_command().

replication_scanner_init()

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

extern

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, fb(), palloc0_object, and str.

Referenced by exec_replication_command().

replication_scanner_is_replication_command()

bool replication_scanner_is_replication_command ( yyscan_t  yyscanner )

extern

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 fb(), 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  )

extern

Definition at line 260 of file repl_scanner.l.

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

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

replication_yylex()

int replication_yylex ( union YYSTYPE *  yylval_param, yyscan_t  yyscanner  )

extern

Referenced by replication_scanner_is_replication_command().

replication_yyparse()

int replication_yyparse ( Node **  replication_parse_result_p, yyscan_t  yyscanner  )

extern

Referenced by exec_replication_command().

WalSndSetState()

void WalSndSetState ( WalSndState  state )

extern

Definition at line 3942 of file walsender.c.

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

References am_walsender, Assert, fb(), MyWalSnd, SpinLockAcquire, and SpinLockRelease.

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