Commite42351a

committed

Simplify some code in logical replication launcher

Avoid unnecessary locking calls when a subscription is disabled.Author: Yugo Nagata <nagata@sraoss.co.jp>

1 parent270fec9 commite42351aCopy full SHA for e42351a

File tree

-1

lines changed

-1

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -929,11 +929,14 @@ ApplyLauncherMain(Datum main_arg)`
`929`	`929`	`Subscriptionsub= (Subscription)lfirst(lc);`
`930`	`930`	`LogicalRepWorker*w;`
`931`	`931`
	`932`	`+if (!sub->enabled)`
	`933`	`+continue;`
	`934`	`+`
`932`	`935`	`LWLockAcquire(LogicalRepWorkerLock,LW_SHARED);`
`933`	`936`	`w=logicalrep_worker_find(sub->oid,InvalidOid, false);`
`934`	`937`	`LWLockRelease(LogicalRepWorkerLock);`
`935`	`938`
`936`		`-if (sub->enabled&&w==NULL)`
	`939`	`+if (w==NULL)`
`937`	`940`	`{`
`938`	`941`	`last_start_time=now;`
`939`	`942`	`wait_time=wal_retrieve_retry_interval;`

Comments

(0)