mirror of https://github.com/citusdata/citus.git
parent
92788a0d9c
commit
e774f22ed4
|
@ -140,7 +140,7 @@ MultiClientConnect(const char *nodeName, uint32 nodePort, const char *nodeDataba
|
|||
}
|
||||
else
|
||||
{
|
||||
ReportRemoteError(connection, NULL);
|
||||
ReportRemoteError(connection, NULL);
|
||||
|
||||
PQfinish(connection);
|
||||
connectionId = INVALID_CONNECTION_ID;
|
||||
|
@ -678,7 +678,7 @@ MultiClientCopyData(int32 connectionId, int32 fileDescriptor)
|
|||
/* received an error */
|
||||
copyStatus = CLIENT_COPY_FAILED;
|
||||
|
||||
ReportRemoteError(connection, NULL);
|
||||
ReportRemoteError(connection, NULL);
|
||||
}
|
||||
|
||||
/* if copy out completed, make sure we drain all results from libpq */
|
||||
|
|
|
@ -64,8 +64,8 @@ PG_FUNCTION_INFO_V1(master_modify_multiple_shards);
|
|||
|
||||
|
||||
/*
|
||||
* master_modify_multiple_shards takes in a DELETE or UPDATE query string and
|
||||
* pushes the query to shards. It finds shards that match the criteria defined
|
||||
* master_modify_multiple_shards takes in a DELETE or UPDATE query string and
|
||||
* pushes the query to shards. It finds shards that match the criteria defined
|
||||
* in the delete command, generates the same delete query string for each of the
|
||||
* found shards with distributed table name replaced with the shard name and
|
||||
* sends the queries to the workers. It uses one-phase or two-phase commit
|
||||
|
|
Loading…
Reference in New Issue