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

Remove unnecessary hash search

pull/366/head
Metin Doslu 2016-03-24 22:21:48 -07:00
parent 69ce21a42f
commit eea877ce4e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/commands/multi_copy.c
View File

@ -380,14 +380,15 @@ CitusCopyFrom(CopyStmt *copyStatement, char *completionTag)
shardConnections = (ShardConnections *) hash_seq_search(&status); shardConnections = (ShardConnections *) hash_seq_search(&status);
while (shardConnections != NULL) while (shardConnections != NULL)
{ {
List *shardConnectionsList = list_copy(shardConnections->connectionList);
connectionList = list_concat(connectionList, shardConnectionsList);
BuildCopyBinaryFooters(copyOutState); BuildCopyBinaryFooters(copyOutState);
SendCopyDataToPlacements(copyOutState->fe_msgbuf, shardConnections); SendCopyDataToPlacements(copyOutState->fe_msgbuf, shardConnections);
shardConnections = (ShardConnections *) hash_seq_search(&status); shardConnections = (ShardConnections *) hash_seq_search(&status);
} }
connectionList = ConnectionList(shardConnectionHash);
EndRemoteCopy(connectionList, true); EndRemoteCopy(connectionList, true);
if (CopyTransactionManager == TRANSACTION_MANAGER_2PC) if (CopyTransactionManager == TRANSACTION_MANAGER_2PC)