mirror of
https://github.com/postgres/postgres.git
synced 2025-10-16 17:07:43 +03:00
Use PqMsg_* macros in applyparallelworker.c.
Oversight in commit f4b54e1ed9
.
Author: Ranier Vilela <ranier.vf@gmail.com>
Discussion: https://postgr.es/m/CAEudQAobFsHaLMypA6C96-9YExvF4AcU1xNPoPuNYRVm3mq4dg%40mail.gmail.com
This commit is contained in:
@@ -1007,7 +1007,7 @@ ProcessParallelApplyMessage(StringInfo msg)
|
|||||||
|
|
||||||
switch (msgtype)
|
switch (msgtype)
|
||||||
{
|
{
|
||||||
case 'E': /* ErrorResponse */
|
case PqMsg_ErrorResponse:
|
||||||
{
|
{
|
||||||
ErrorData edata;
|
ErrorData edata;
|
||||||
|
|
||||||
@@ -1044,11 +1044,11 @@ ProcessParallelApplyMessage(StringInfo msg)
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Don't need to do anything about NoticeResponse and
|
* Don't need to do anything about NoticeResponse and
|
||||||
* NotifyResponse as the logical replication worker doesn't need
|
* NotificationResponse as the logical replication worker doesn't
|
||||||
* to send messages to the client.
|
* need to send messages to the client.
|
||||||
*/
|
*/
|
||||||
case 'N':
|
case PqMsg_NoticeResponse:
|
||||||
case 'A':
|
case PqMsg_NotificationResponse:
|
||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
|
Reference in New Issue
Block a user