database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-07-27 12:41:57 +03:00
Code Activity

Simplify some of the logical replication worker-type checks.

Browse Source 
Author: Peter Smith
Reviewed-by: Hou Zhijie
Discussion: http://postgr.es/m/CAHut+Pv-xkEpuPzbEJ=ZSi7Hp2RoGJf=VA-uDRxLi1KHSneFjg@mail.gmail.com
This commit is contained in:
Amit Kapila
2023-08-04 08:15:07 +05:30
parent 7516056c58
commit 81ccbe520f
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/replication/logical/worker.c
View File

@ -3863,7 +3863,7 @@ apply_worker_exit(void)
* subscription is still active, and so that we won't leak that hash table * subscription is still active, and so that we won't leak that hash table
* entry if it isn't. * entry if it isn't.
*/ */
if (!am_tablesync_worker()) if (am_leader_apply_worker())
ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid); ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid);
proc_exit(0); proc_exit(0);
@ -3906,8 +3906,9 @@ maybe_reread_subscription(void)
MySubscription->name))); MySubscription->name)));
/* Ensure we remove no-longer-useful entry for worker's start time */ /* Ensure we remove no-longer-useful entry for worker's start time */
if (!am_tablesync_worker() && !am_parallel_apply_worker()) if (am_leader_apply_worker())
ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid); ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid);
proc_exit(0); proc_exit(0);
} }
@ -4589,8 +4590,9 @@ InitializeLogRepWorker(void)
MyLogicalRepWorker->subid))); MyLogicalRepWorker->subid)));
/* Ensure we remove no-longer-useful entry for worker's start time */ /* Ensure we remove no-longer-useful entry for worker's start time */
if (!am_tablesync_worker() && !am_parallel_apply_worker()) if (am_leader_apply_worker())
ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid); ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid);
proc_exit(0); proc_exit(0);
} }
@ -4715,7 +4717,7 @@ DisableSubscriptionAndExit(void)
CommitTransactionCommand(); CommitTransactionCommand();
/* Ensure we remove no-longer-useful entry for worker's start time */ /* Ensure we remove no-longer-useful entry for worker's start time */
if (!am_tablesync_worker() && !am_parallel_apply_worker()) if (am_leader_apply_worker())
ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid); ApplyLauncherForgetWorkerStartTime(MyLogicalRepWorker->subid);
/* Notify the subscription has been disabled and exit */ /* Notify the subscription has been disabled and exit */