PostgreSQL Source Code  git master
logicalworker.h
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * logicalworker.h
4  * Exports for logical replication workers.
5  *
6  * Portions Copyright (c) 2016-2024, PostgreSQL Global Development Group
7  *
8  * src/include/replication/logicalworker.h
9  *
10  *-------------------------------------------------------------------------
11  */
12 #ifndef LOGICALWORKER_H
13 #define LOGICALWORKER_H
14 
15 #include <signal.h>
16 
17 extern PGDLLIMPORT volatile sig_atomic_t ParallelApplyMessagePending;
18 
19 extern void ApplyWorkerMain(Datum main_arg);
20 extern void ParallelApplyWorkerMain(Datum main_arg);
21 extern void TablesyncWorkerMain(Datum main_arg);
22 
23 extern bool IsLogicalWorker(void);
24 extern bool IsLogicalParallelApplyWorker(void);
25 
26 extern void HandleParallelApplyMessageInterrupt(void);
27 extern void HandleParallelApplyMessages(void);
28 
29 extern void LogicalRepWorkersWakeupAtCommit(Oid subid);
30 
31 extern void AtEOXact_LogicalRepWorkers(bool isCommit);
32 
33 #endif /* LOGICALWORKER_H */
#define PGDLLIMPORT
Definition: c.h:1316
void HandleParallelApplyMessageInterrupt(void)
void TablesyncWorkerMain(Datum main_arg)
Definition: tablesync.c:1711
void LogicalRepWorkersWakeupAtCommit(Oid subid)
Definition: worker.c:4989
bool IsLogicalWorker(void)
Definition: worker.c:4744
bool IsLogicalParallelApplyWorker(void)
Definition: worker.c:4753
void AtEOXact_LogicalRepWorkers(bool isCommit)
Definition: worker.c:5003
PGDLLIMPORT volatile sig_atomic_t ParallelApplyMessagePending
void ApplyWorkerMain(Datum main_arg)
Definition: worker.c:4685
void ParallelApplyWorkerMain(Datum main_arg)
void HandleParallelApplyMessages(void)
uintptr_t Datum
Definition: postgres.h:64
unsigned int Oid
Definition: postgres_ext.h:31