diff options
Diffstat (limited to 'src/backend/access/transam/parallel.c')
| -rw-r--r-- | src/backend/access/transam/parallel.c | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/src/backend/access/transam/parallel.c b/src/backend/access/transam/parallel.c index cbfe6087da4..798cd86c881 100644 --- a/src/backend/access/transam/parallel.c +++ b/src/backend/access/transam/parallel.c @@ -1131,16 +1131,6 @@ HandleParallelMessage(ParallelContext *pcxt, int i, StringInfo msg) switch (msgtype) { - case PqMsg_BackendKeyData: - { - int32 pid = pq_getmsgint(msg, 4); - - (void) pq_getmsgint(msg, 4); /* discard cancel key */ - (void) pq_getmsgend(msg); - pcxt->worker[i].pid = pid; - break; - } - case PqMsg_ErrorResponse: case PqMsg_NoticeResponse: { @@ -1304,7 +1294,6 @@ ParallelWorkerMain(Datum main_arg) char *relmapperspace; char *uncommittedenumsspace; char *clientconninfospace; - StringInfoData msgbuf; char *session_dsm_handle_space; Snapshot tsnapshot; Snapshot asnapshot; @@ -1370,18 +1359,6 @@ ParallelWorkerMain(Datum main_arg) fps->parallel_leader_proc_number); /* - * Send a BackendKeyData message to the process that initiated parallelism - * so that it has access to our PID before it receives any other messages - * from us. Our cancel key is sent, too, since that's the way the - * protocol message is defined, but it won't actually be used for anything - * in this case. - */ - pq_beginmessage(&msgbuf, PqMsg_BackendKeyData); - pq_sendint32(&msgbuf, (int32) MyProcPid); - pq_sendint32(&msgbuf, (int32) MyCancelKey); - pq_endmessage(&msgbuf); - - /* * Hooray! Primary initialization is complete. Now, we need to set up our * backend-local state to match the original backend. */ |