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

Merge pull request #1878 from citusdata/log_remote_command 

Log remote commands sent via MultiClientSendQuery
pull/1897/head
Marco Slot 2017-12-22 17:30:18 +01:00 committed by GitHub
parent 87c6f306f1 fa7fa2734b
commit a2e2419ad1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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];
Assert(connection != NULL);
querySent = PQsendQuery(connection->pgConn, query);
querySent = SendRemoteCommand(connection, query);
if (querySent == 0)
{
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;
}
/*
* NB: this intentionally uses PQsendQuery rather than
* SendRemoteCommand as multiple commands are allowed.
*/
querySent = PQsendQuery(connection->pgConn, queryString);
querySent = SendRemoteCommand(connection, queryString);
if (querySent == 0)
{
StoreErrorMessage(connection, queryResultString);