external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Log user in the failed connection message

pull/7432/head
Filip Sedlák 2024-01-19 14:21:20 +01:00 committed by Filip Sedlak
parent 14ecebe47c
commit 0e287b1450
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/distributed/connection/remote_commands.c
View File

@ -246,6 +246,7 @@ ClearResultsIfReady(MultiConnection *connection)
void void
ReportConnectionError(MultiConnection *connection, int elevel) ReportConnectionError(MultiConnection *connection, int elevel)
{ {
char *userName = connection->user;
char *nodeName = connection->hostname; char *nodeName = connection->hostname;
int nodePort = connection->port; int nodePort = connection->port;
PGconn *pgConn = connection->pgConn; PGconn *pgConn = connection->pgConn;
@ -264,15 +265,15 @@ ReportConnectionError(MultiConnection *connection, int elevel)
if (messageDetail) if (messageDetail)
{ {
ereport(elevel, (errcode(ERRCODE_CONNECTION_FAILURE), ereport(elevel, (errcode(ERRCODE_CONNECTION_FAILURE),
errmsg("connection to the remote node %s:%d failed with the " errmsg("connection to the remote node %s@%s:%d failed with the "
"following error: %s", nodeName, nodePort, "following error: %s", userName, nodeName, nodePort,
messageDetail))); messageDetail)));
} }
else else
{ {
ereport(elevel, (errcode(ERRCODE_CONNECTION_FAILURE), ereport(elevel, (errcode(ERRCODE_CONNECTION_FAILURE),
errmsg("connection to the remote node %s:%d failed", errmsg("connection to the remote node %s@%s:%d failed",
nodeName, nodePort))); userName, nodeName, nodePort)));
} }
} }

2
src/test/regress/expected/detect_conn_close.out
View File

@ -128,7 +128,7 @@ BEGIN;
(1 row) (1 row)
SELECT count(*) FROM socket_test_table; SELECT count(*) FROM socket_test_table;
ERROR: connection to the remote node localhost:xxxxx failed with the following error: connection not open ERROR: connection to the remote node postgres@localhost:xxxxx failed with the following error: connection not open
ROLLBACK; ROLLBACK;
-- repartition joins also can recover -- repartition joins also can recover
SET citus.enable_repartition_joins TO on; SET citus.enable_repartition_joins TO on;