003_005_Fix_ApplyLancherWakeUp_function_v3.patch
application/octet-stream
Filename: 003_005_Fix_ApplyLancherWakeUp_function_v3.patch
Type: application/octet-stream
Part: 5
Patch
Format: unified
Series: patch v3
| File | + | − |
|---|---|---|
| src/backend/replication/logical/launcher.c | 3 | 2 |
| src/include/replication/logicallauncher.h | 0 | 1 |
diff --git a/src/backend/replication/logical/launcher.c b/src/backend/replication/logical/launcher.c
index 2d663f6..c025d6b 100644
--- a/src/backend/replication/logical/launcher.c
+++ b/src/backend/replication/logical/launcher.c
@@ -72,6 +72,7 @@ typedef struct LogicalRepCtxStruct
LogicalRepCtxStruct *LogicalRepCtx;
+static void ApplyLauncherWakeup(void);
static void logicalrep_worker_onexit(int code, Datum arg);
static void logicalrep_worker_detach(void);
@@ -637,10 +638,10 @@ ApplyLauncherWakeupAtCommit(void)
on_commit_launcher_wakeup = true;
}
-void
+static void
ApplyLauncherWakeup(void)
{
- if (IsBackendPid(LogicalRepCtx->launcher_pid))
+ if (LogicalRepCtx->launcher_pid != 0)
kill(LogicalRepCtx->launcher_pid, SIGUSR1);
}
diff --git a/src/include/replication/logicallauncher.h b/src/include/replication/logicallauncher.h
index 060946a..0c2bf03 100644
--- a/src/include/replication/logicallauncher.h
+++ b/src/include/replication/logicallauncher.h
@@ -21,7 +21,6 @@ extern void ApplyLauncherMain(Datum main_arg);
extern Size ApplyLauncherShmemSize(void);
extern void ApplyLauncherShmemInit(void);
-extern void ApplyLauncherWakeup(void);
extern void ApplyLauncherWakeupAtCommit(void);
extern void AtCommit_ApplyLauncher(void);