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

Log remote commands sent via MultiClientSendQuery

pull/1878/head
Marco Slot 2017-12-14 15:51:37 +01:00
parent 87c6f306f1
commit fa7fa2734b
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/executor/multi_client_executor.c
View File

@ -397,7 +397,7 @@ MultiClientSendQuery(int32 connectionId, const char *query)
connection = ClientConnectionArray[connectionId]; connection = ClientConnectionArray[connectionId];
Assert(connection != NULL); Assert(connection != NULL);
querySent = PQsendQuery(connection->pgConn, query); querySent = SendRemoteCommand(connection, query);
if (querySent == 0) if (querySent == 0)
{ {
char *errorMessage = pchomp(PQerrorMessage(connection->pgConn)); char *errorMessage = pchomp(PQerrorMessage(connection->pgConn));

7
src/backend/distributed/master/master_citus_tools.c
View File

@ -271,12 +271,7 @@ ExecuteCommandsInParallelAndStoreResults(StringInfo *nodeNameArray, int *nodePor
continue; continue;
} }
/* querySent = SendRemoteCommand(connection, queryString);
* NB: this intentionally uses PQsendQuery rather than
* SendRemoteCommand as multiple commands are allowed.
*/
querySent = PQsendQuery(connection->pgConn, queryString);
if (querySent == 0) if (querySent == 0)
{ {
StoreErrorMessage(connection, queryResultString); StoreErrorMessage(connection, queryResultString);