diff options
| author | Amit Kapila <akapila@postgresql.org> | 2023-08-14 08:38:03 +0530 |
|---|---|---|
| committer | Amit Kapila <akapila@postgresql.org> | 2023-08-14 08:38:03 +0530 |
| commit | 2a8b40e3681921943a2989fd4ec6cdbf8766566c (patch) | |
| tree | a5c55ec41deb79663ab7b9585f63bd6b1dcd3ad7 /src/backend/replication/logical/applyparallelworker.c | |
| parent | 3d8d217450a63638825167c17ed791122f376176 (diff) | |
| download | postgresql-2a8b40e3681921943a2989fd4ec6cdbf8766566c.tar.gz postgresql-2a8b40e3681921943a2989fd4ec6cdbf8766566c.zip | |
Simplify determining logical replication worker types.
We deduce a LogicalRepWorker's type from the values of several different
fields ('relid' and 'leader_pid') whenever logic needs to know it.
In fact, the logical replication worker type is already known at the time
of launching the LogicalRepWorker and it never changes for the lifetime of
that process. Instead of deducing the type, it is simpler to just store it
one time, and access it directly thereafter.
Author: Peter Smith
Reviewed-by: Amit Kapila, Bharath Rupireddy
Discussion: http://postgr.es/m/CAHut+PttPSuP0yoZ=9zLDXKqTJ=d0bhxwKaEaNcaym1XqcvDEg@mail.gmail.com
Diffstat (limited to 'src/backend/replication/logical/applyparallelworker.c')
| -rw-r--r-- | src/backend/replication/logical/applyparallelworker.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/backend/replication/logical/applyparallelworker.c b/src/backend/replication/logical/applyparallelworker.c index 1d4e83c4c1f..4e8ee2973e0 100644 --- a/src/backend/replication/logical/applyparallelworker.c +++ b/src/backend/replication/logical/applyparallelworker.c @@ -435,7 +435,8 @@ pa_launch_parallel_worker(void) return NULL; } - launched = logicalrep_worker_launch(MyLogicalRepWorker->dbid, + launched = logicalrep_worker_launch(WORKERTYPE_PARALLEL_APPLY, + MyLogicalRepWorker->dbid, MySubscription->oid, MySubscription->name, MyLogicalRepWorker->userid, |