diff options
Diffstat (limited to 'src/backend/access/transam/parallel.c')
| -rw-r--r-- | src/backend/access/transam/parallel.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/backend/access/transam/parallel.c b/src/backend/access/transam/parallel.c index f6d81d6e1fc..94db1ec3012 100644 --- a/src/backend/access/transam/parallel.c +++ b/src/backend/access/transam/parallel.c @@ -158,7 +158,7 @@ static const struct }; /* Private functions. */ -static void HandleParallelMessage(ParallelContext *pcxt, int i, StringInfo msg); +static void ProcessParallelMessage(ParallelContext *pcxt, int i, StringInfo msg); static void WaitForParallelWorkersToExit(ParallelContext *pcxt); static parallel_worker_main_type LookupParallelWorkerFunction(const char *libraryname, const char *funcname); static void ParallelWorkerShutdown(int code, Datum arg); @@ -1031,7 +1031,7 @@ ParallelContextActive(void) * * Note: this is called within a signal handler! All we can do is set * a flag that will cause the next CHECK_FOR_INTERRUPTS() to invoke - * HandleParallelMessages(). + * ProcessParallelMessages(). */ void HandleParallelMessageInterrupt(void) @@ -1042,10 +1042,10 @@ HandleParallelMessageInterrupt(void) } /* - * Handle any queued protocol messages received from parallel workers. + * Process any queued protocol messages received from parallel workers. */ void -HandleParallelMessages(void) +ProcessParallelMessages(void) { dlist_iter iter; MemoryContext oldcontext; @@ -1068,7 +1068,7 @@ HandleParallelMessages(void) */ if (hpm_context == NULL) /* first time through? */ hpm_context = AllocSetContextCreate(TopMemoryContext, - "HandleParallelMessages", + "ProcessParallelMessages", ALLOCSET_DEFAULT_SIZES); else MemoryContextReset(hpm_context); @@ -1111,7 +1111,7 @@ HandleParallelMessages(void) initStringInfo(&msg); appendBinaryStringInfo(&msg, data, nbytes); - HandleParallelMessage(pcxt, i, &msg); + ProcessParallelMessage(pcxt, i, &msg); pfree(msg.data); } else @@ -1131,10 +1131,10 @@ HandleParallelMessages(void) } /* - * Handle a single protocol message received from a single parallel worker. + * Process a single protocol message received from a single parallel worker. */ static void -HandleParallelMessage(ParallelContext *pcxt, int i, StringInfo msg) +ProcessParallelMessage(ParallelContext *pcxt, int i, StringInfo msg) { char msgtype; |