diff options
| author | Peter Eisentraut <peter_e@gmx.net> | 2017-08-15 15:13:06 -0400 |
|---|---|---|
| committer | Peter Eisentraut <peter_e@gmx.net> | 2017-08-15 15:13:06 -0400 |
| commit | e42351ae07c19bb4eaedbdce8ccd4dfb4e905069 (patch) | |
| tree | 9dd8cc39da4480ee1d6621a8841084d34c9cf771 /src | |
| parent | 270fec9f0bc9082ed99f0c447d450bd8cd92be73 (diff) | |
| download | postgresql-e42351ae07c19bb4eaedbdce8ccd4dfb4e905069.tar.gz postgresql-e42351ae07c19bb4eaedbdce8ccd4dfb4e905069.zip | |
Simplify some code in logical replication launcher
Avoid unnecessary locking calls when a subscription is disabled.
Author: Yugo Nagata <nagata@sraoss.co.jp>
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/replication/logical/launcher.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/backend/replication/logical/launcher.c b/src/backend/replication/logical/launcher.c index 4c6d4b27723..6c894421a39 100644 --- a/src/backend/replication/logical/launcher.c +++ b/src/backend/replication/logical/launcher.c @@ -929,11 +929,14 @@ ApplyLauncherMain(Datum main_arg) Subscription *sub = (Subscription *) lfirst(lc); LogicalRepWorker *w; + if (!sub->enabled) + continue; + LWLockAcquire(LogicalRepWorkerLock, LW_SHARED); w = logicalrep_worker_find(sub->oid, InvalidOid, false); LWLockRelease(LogicalRepWorkerLock); - if (sub->enabled && w == NULL) + if (w == NULL) { last_start_time = now; wait_time = wal_retrieve_retry_interval; |