#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/latch.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 (void)

int	replication_yylex (void)

void	replication_yyerror (const char *message) pg_attribute_noreturn()

void	replication_scanner_init (const char *str)

void	replication_scanner_finish (void)

bool	replication_scanner_is_replication_command (void)

Variables
PGDLLIMPORT WalSnd *	MyWalSnd

PGDLLIMPORT WalSndCtlData *	WalSndCtl

PGDLLIMPORT Node *	replication_parse_result

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 25 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 ( void )

Referenced by exec_replication_command().

◆ replication_scanner_init()

void replication_scanner_init ( const char * str )

Referenced by exec_replication_command().

◆ replication_scanner_is_replication_command()

bool replication_scanner_is_replication_command ( void )

Referenced by exec_replication_command().

◆ replication_yyerror()

void replication_yyerror ( const char * message )

◆ replication_yylex()

int replication_yylex ( void )

◆ replication_yyparse()

int replication_yyparse ( void )

Referenced by exec_replication_command().

◆ WalSndSetState()

void WalSndSetState ( WalSndState state )

Definition at line 3809 of file walsender.c.

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