PostgreSQL Source Code  git master
walsender.h
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * walsender.h
4  * Exports from replication/walsender.c.
5  *
6  * Portions Copyright (c) 2010-2022, PostgreSQL Global Development Group
7  *
8  * src/include/replication/walsender.h
9  *
10  *-------------------------------------------------------------------------
11  */
12 #ifndef _WALSENDER_H
13 #define _WALSENDER_H
14 
15 #include <signal.h>
16 
17 /*
18  * What to do with a snapshot in create replication slot command.
19  */
20 typedef enum
21 {
26 
27 /* global state */
28 extern PGDLLIMPORT bool am_walsender;
30 extern PGDLLIMPORT bool am_db_walsender;
31 extern PGDLLIMPORT bool wake_wal_senders;
32 
33 /* user-settable parameters */
34 extern PGDLLIMPORT int max_wal_senders;
37 
38 extern void InitWalSender(void);
39 extern bool exec_replication_command(const char *query_string);
40 extern void WalSndErrorCleanup(void);
41 extern void WalSndResourceCleanup(bool isCommit);
42 extern void WalSndSignals(void);
43 extern Size WalSndShmemSize(void);
44 extern void WalSndShmemInit(void);
45 extern void WalSndWakeup(void);
46 extern void WalSndInitStopping(void);
47 extern void WalSndWaitStopping(void);
48 extern void HandleWalSndInitStopping(void);
49 extern void WalSndRqstFileReload(void);
50 
51 /*
52  * Remember that we want to wakeup walsenders later
53  *
54  * This is separated from doing the actual wakeup because the writeout is done
55  * while holding contended locks.
56  */
57 #define WalSndWakeupRequest() \
58  do { wake_wal_senders = true; } while (0)
59 
60 /*
61  * wakeup walsenders if there is work to be done
62  */
63 #define WalSndWakeupProcessRequests() \
64  do \
65  { \
66  if (wake_wal_senders) \
67  { \
68  wake_wal_senders = false; \
69  if (max_wal_senders > 0) \
70  WalSndWakeup(); \
71  } \
72  } while (0)
73 
74 #endif /* _WALSENDER_H */
#define PGDLLIMPORT
Definition: c.h:1331
size_t Size
Definition: c.h:540
void WalSndWakeup(void)
Definition: walsender.c:3309
PGDLLIMPORT bool wake_wal_senders
Definition: walsender.c:131
void WalSndErrorCleanup(void)
Definition: walsender.c:315
PGDLLIMPORT bool am_cascading_walsender
Definition: walsender.c:117
void WalSndShmemInit(void)
Definition: walsender.c:3277
PGDLLIMPORT bool am_db_walsender
Definition: walsender.c:119
void InitWalSender(void)
void WalSndInitStopping(void)
Definition: walsender.c:3354
void WalSndWaitStopping(void)
Definition: walsender.c:3380
void WalSndResourceCleanup(bool isCommit)
Definition: walsender.c:350
PGDLLIMPORT int max_wal_senders
Definition: walsender.c:122
PGDLLIMPORT bool log_replication_commands
Definition: walsender.c:126
void WalSndRqstFileReload(void)
Definition: walsender.c:3189
Size WalSndShmemSize(void)
Definition: walsender.c:3265
void HandleWalSndInitStopping(void)
Definition: walsender.c:3212
PGDLLIMPORT int wal_sender_timeout
Definition: walsender.c:124
PGDLLIMPORT bool am_walsender
Definition: walsender.c:116
void WalSndSignals(void)
Definition: walsender.c:3246
CRSSnapshotAction
Definition: walsender.h:21
@ CRS_USE_SNAPSHOT
Definition: walsender.h:24
@ CRS_NOEXPORT_SNAPSHOT
Definition: walsender.h:23
@ CRS_EXPORT_SNAPSHOT
Definition: walsender.h:22
bool exec_replication_command(const char *query_string)
Definition: walsender.c:1682