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-2023, 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 *cmd_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(bool physical, bool logical);
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 static inline void
64 WalSndWakeupProcessRequests(bool physical, bool logical)
65 {
66  if (wake_wal_senders)
67  {
68  wake_wal_senders = false;
69  if (max_wal_senders > 0)
70  WalSndWakeup(physical, logical);
71  }
72 }
73 
74 #endif /* _WALSENDER_H */
#define PGDLLIMPORT
Definition: c.h:1326
size_t Size
Definition: c.h:594
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 WalSndWakeup(bool physical, bool logical)
Definition: walsender.c:3333
void WalSndShmemInit(void)
Definition: walsender.c:3289
PGDLLIMPORT bool am_db_walsender
Definition: walsender.c:119
bool exec_replication_command(const char *cmd_string)
Definition: walsender.c:1672
void InitWalSender(void)
static void WalSndWakeupProcessRequests(bool physical, bool logical)
Definition: walsender.h:64
void WalSndInitStopping(void)
Definition: walsender.c:3406
void WalSndWaitStopping(void)
Definition: walsender.c:3432
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:3201
Size WalSndShmemSize(void)
Definition: walsender.c:3277
void HandleWalSndInitStopping(void)
Definition: walsender.c:3224
PGDLLIMPORT int wal_sender_timeout
Definition: walsender.c:124
PGDLLIMPORT bool am_walsender
Definition: walsender.c:116
void WalSndSignals(void)
Definition: walsender.c:3258
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