diff options
Diffstat (limited to 'src/backend/replication/logical/applyparallelworker.c')
| -rw-r--r-- | src/backend/replication/logical/applyparallelworker.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/backend/replication/logical/applyparallelworker.c b/src/backend/replication/logical/applyparallelworker.c index fb79ee1e7bf..e7f7d4c5e4b 100644 --- a/src/backend/replication/logical/applyparallelworker.c +++ b/src/backend/replication/logical/applyparallelworker.c @@ -845,7 +845,7 @@ pa_shutdown(int code, Datum arg) { SendProcSignal(MyLogicalRepWorker->leader_pid, PROCSIG_PARALLEL_APPLY_MESSAGE, - InvalidBackendId); + INVALID_PROC_NUMBER); dsm_detach((dsm_segment *) DatumGetPointer(arg)); } @@ -934,7 +934,7 @@ ParallelApplyWorkerMain(Datum main_arg) pq_redirect_to_shm_mq(seg, error_mqh); pq_set_parallel_leader(MyLogicalRepWorker->leader_pid, - InvalidBackendId); + INVALID_PROC_NUMBER); MyLogicalRepWorker->last_send_time = MyLogicalRepWorker->last_recv_time = MyLogicalRepWorker->reply_time = 0; |