database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-10-16 17:07:43 +03:00
Code Activity

Use PqMsg_* macros in fe-protocol3.c.

Browse Source 
Oversight in commit f4b54e1ed9.

Reviewed-by: Jacob Champion <jacob.champion@enterprisedb.com>
Reviewed-by: Fabrízio de Royes Mello <fabriziomello@gmail.com>
Discussion: https://postgr.es/m/aKx5vEbbP03JNgtp%40nathan
This commit is contained in:
Nathan Bossart
2025-08-25 11:08:26 -05:00
parent 878656dbde
commit 3ef2b863a3
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/include/libpq/protocol.h
View File

@@ -66,6 +66,7 @@
/* These are the codes sent by parallel workers to leader processes. */ /* These are the codes sent by parallel workers to leader processes. */
#define PqMsg_Progress 'P' #define PqMsg_Progress 'P'

12
src/interfaces/libpq/fe-protocol3.c
View File

@@ -2262,7 +2262,7 @@ pqFunctionCall3(PGconn *conn, Oid fnid,
*/ */
switch (id) switch (id)
{ {
case 'V': /* function result */ case PqMsg_FunctionCallResponse:
if (pqGetInt(actual_result_len, 4, conn)) if (pqGetInt(actual_result_len, 4, conn))
continue; continue;
if (*actual_result_len != -1) if (*actual_result_len != -1)
@@ -2283,22 +2283,22 @@ pqFunctionCall3(PGconn *conn, Oid fnid,
/* correctly finished function result message */ /* correctly finished function result message */
status = PGRES_COMMAND_OK; status = PGRES_COMMAND_OK;
break; break;
case 'E': /* error return */ case PqMsg_ErrorResponse:
if (pqGetErrorNotice3(conn, true)) if (pqGetErrorNotice3(conn, true))
continue; continue;
status = PGRES_FATAL_ERROR; status = PGRES_FATAL_ERROR;
break; break;
case 'A': /* notify message */ case PqMsg_NotificationResponse:
/* handle notify and go back to processing return values */ /* handle notify and go back to processing return values */
if (getNotify(conn)) if (getNotify(conn))
continue; continue;
break; break;
case 'N': /* notice */ case PqMsg_NoticeResponse:
/* handle notice and go back to processing return values */ /* handle notice and go back to processing return values */
if (pqGetErrorNotice3(conn, false)) if (pqGetErrorNotice3(conn, false))
continue; continue;
break; break;
case 'Z': /* backend is ready for new query */ case PqMsg_ReadyForQuery:
if (getReadyForQuery(conn)) if (getReadyForQuery(conn))
continue; continue;
@@ -2330,7 +2330,7 @@ pqFunctionCall3(PGconn *conn, Oid fnid,
} }
/* and we're out */ /* and we're out */
return pqPrepareAsyncResult(conn); return pqPrepareAsyncResult(conn);
case 'S': /* parameter status */ case PqMsg_ParameterStatus:
if (getParameterStatus(conn)) if (getParameterStatus(conn))
continue; continue;
break; break;