mirrors/postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix the display of UNKNOWN message type in apply worker.

Browse Source 
We include the message type while displaying an error context in the
apply worker. Now, while retrieving the message type string if the
message type is unknown we throw an error that will hide the original
error. So, instead, we need to simply return the string indicating an
unknown message type.

Reported-by: Ashutosh Bapat
Author: Euler Taveira, Amit Kapila
Reviewed-by: Ashutosh Bapat
Backpatch-through: 15
Discussion: https://postgr.es/m/CAExHW5suAEDW-mBZt_qu4RVxWZ1vL54-L+ci2zreYWebpzxYsA@mail.gmail.com
This commit is contained in:
Amit Kapila 2023-07-25 08:50:37 +05:30
parent 3bb8b9342f
commit 2864eb977a
3 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/backend/replication/logical/proto.c
View File

@ -1194,9 +1194,11 @@ logicalrep_read_stream_abort(StringInfo in, TransactionId *xid,
/*
* Get string representing LogicalRepMsgType.
*/
char *
const char *
logicalrep_message_type(LogicalRepMsgType action)
{
static char err_unknown[20];
switch (action)
{
case LOGICAL_REP_MSG_BEGIN:
@ -1239,7 +1241,12 @@ logicalrep_message_type(LogicalRepMsgType action)
return "STREAM PREPARE";
}
elog(ERROR, "invalid logical replication message type \"%c\"", action);
/*
* This message provides context in the error raised when applying a
* logical message. So we can't throw an error here. Return an unknown
* indicator value so that the original error is still reported.
*/
snprintf(err_unknown, sizeof(err_unknown), "??? (%d)", action);
return NULL; /* keep compiler quiet */
return err_unknown;
}

2
src/backend/replication/logical/worker.c
View File

@ -2579,7 +2579,7 @@ apply_dispatch(StringInfo s)
default:
ereport(ERROR,
(errcode(ERRCODE_PROTOCOL_VIOLATION),
errmsg("invalid logical replication message type \"%c\"", action)));
errmsg("invalid logical replication message type \"??? (%d)\"", action)));
}
/* Reset the current command */

2
src/include/replication/logicalproto.h
View File

@ -249,6 +249,6 @@ extern void logicalrep_write_stream_abort(StringInfo out, TransactionId xid,
TransactionId subxid);
extern void logicalrep_read_stream_abort(StringInfo in, TransactionId *xid,
TransactionId *subxid);
extern char *logicalrep_message_type(LogicalRepMsgType action);
extern const char *logicalrep_message_type(LogicalRepMsgType action);
#endif /* LOGICAL_PROTO_H */