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-2025, 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
17extern PGDLLIMPORT volatile sig_atomic_t ParallelApplyMessagePending;
18
19extern void ApplyWorkerMain(Datum main_arg);
20extern void ParallelApplyWorkerMain(Datum main_arg);
21extern void TableSyncWorkerMain(Datum main_arg);
22extern void SequenceSyncWorkerMain(Datum main_arg);
23
24extern bool IsLogicalWorker(void);
25extern bool IsLogicalParallelApplyWorker(void);
26
28extern void ProcessParallelApplyMessages(void);
29
30extern void LogicalRepWorkersWakeupAtCommit(Oid subid);
31
32extern void AtEOXact_LogicalRepWorkers(bool isCommit);
33
34#endif /* LOGICALWORKER_H */
#define PGDLLIMPORT
Definition: c.h:1310
void HandleParallelApplyMessageInterrupt(void)
void ProcessParallelApplyMessages(void)
void LogicalRepWorkersWakeupAtCommit(Oid subid)
Definition: worker.c:6255
bool IsLogicalWorker(void)
Definition: worker.c:6002
void TableSyncWorkerMain(Datum main_arg)
Definition: tablesync.c:1580
bool IsLogicalParallelApplyWorker(void)
Definition: worker.c:6011
void AtEOXact_LogicalRepWorkers(bool isCommit)
Definition: worker.c:6269
void SequenceSyncWorkerMain(Datum main_arg)
Definition: sequencesync.c:746
PGDLLIMPORT volatile sig_atomic_t ParallelApplyMessagePending
void ApplyWorkerMain(Datum main_arg)
Definition: worker.c:5923
void ParallelApplyWorkerMain(Datum main_arg)
uint64_t Datum
Definition: postgres.h:70
unsigned int Oid
Definition: postgres_ext.h:32