77 lines
2.0 KiB
C
77 lines
2.0 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* walsender.h
|
|
* Exports from replication/walsender.c.
|
|
*
|
|
* Portions Copyright (c) 2010-2024, PostgreSQL Global Development Group
|
|
*
|
|
* src/include/replication/walsender.h
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef _WALSENDER_H
|
|
#define _WALSENDER_H
|
|
|
|
#include "access/xlogdefs.h"
|
|
|
|
/*
|
|
* What to do with a snapshot in create replication slot command.
|
|
*/
|
|
typedef enum
|
|
{
|
|
CRS_EXPORT_SNAPSHOT,
|
|
CRS_NOEXPORT_SNAPSHOT,
|
|
CRS_USE_SNAPSHOT,
|
|
} CRSSnapshotAction;
|
|
|
|
/* global state */
|
|
extern PGDLLIMPORT bool am_walsender;
|
|
extern PGDLLIMPORT bool am_cascading_walsender;
|
|
extern PGDLLIMPORT bool am_db_walsender;
|
|
extern PGDLLIMPORT bool wake_wal_senders;
|
|
|
|
/* user-settable parameters */
|
|
extern PGDLLIMPORT int max_wal_senders;
|
|
extern PGDLLIMPORT int wal_sender_timeout;
|
|
extern PGDLLIMPORT bool log_replication_commands;
|
|
|
|
extern void InitWalSender(void);
|
|
extern bool exec_replication_command(const char *cmd_string);
|
|
extern void WalSndErrorCleanup(void);
|
|
extern void WalSndResourceCleanup(bool isCommit);
|
|
extern void PhysicalWakeupLogicalWalSnd(void);
|
|
extern XLogRecPtr GetStandbyFlushRecPtr(TimeLineID *tli);
|
|
extern void WalSndSignals(void);
|
|
extern Size WalSndShmemSize(void);
|
|
extern void WalSndShmemInit(void);
|
|
extern void WalSndWakeup(bool physical, bool logical);
|
|
extern void WalSndInitStopping(void);
|
|
extern void WalSndWaitStopping(void);
|
|
extern void HandleWalSndInitStopping(void);
|
|
extern void WalSndRqstFileReload(void);
|
|
|
|
/*
|
|
* Remember that we want to wakeup walsenders later
|
|
*
|
|
* This is separated from doing the actual wakeup because the writeout is done
|
|
* while holding contended locks.
|
|
*/
|
|
#define WalSndWakeupRequest() \
|
|
do { wake_wal_senders = true; } while (0)
|
|
|
|
/*
|
|
* wakeup walsenders if there is work to be done
|
|
*/
|
|
static inline void
|
|
WalSndWakeupProcessRequests(bool physical, bool logical)
|
|
{
|
|
if (wake_wal_senders)
|
|
{
|
|
wake_wal_senders = false;
|
|
if (max_wal_senders > 0)
|
|
WalSndWakeup(physical, logical);
|
|
}
|
|
}
|
|
|
|
#endif /* _WALSENDER_H */
|