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:14:08 -0400 |
| commit | 292d9b66e2251df4767a43d78927a614561a21d6 (patch) | |
| tree | 0a50f8ea0f3238445ea9bd79c3cdc3996fb9b33d /src | |
| parent | 4e7cd035abaae16e45305417073e7009518acc61 (diff) | |
| download | postgresql-292d9b66e2251df4767a43d78927a614561a21d6.tar.gz postgresql-292d9b66e2251df4767a43d78927a614561a21d6.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; |