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

Use FinishConnectionListEstablishment() instead of manually iterating.

pull/1104/head
Andres Freund 2017-01-06 09:16:01 -08:00
parent d256f3fca9
commit 6291998ae1
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/transaction/multi_shard_transaction.c
View File

@ -44,7 +44,6 @@ OpenTransactionsToAllShardPlacements(List *shardIntervalList, char *userName)
{ {
ListCell *shardIntervalCell = NULL; ListCell *shardIntervalCell = NULL;
List *newConnectionList = NIL; List *newConnectionList = NIL;
ListCell *connectionCell = NULL;
if (shardConnectionHash == NULL) if (shardConnectionHash == NULL)
{ {
@ -121,12 +120,7 @@ OpenTransactionsToAllShardPlacements(List *shardIntervalList, char *userName)
} }
/* finish connection establishment newly opened connections */ /* finish connection establishment newly opened connections */
foreach(connectionCell, newConnectionList) FinishConnectionListEstablishment(newConnectionList);
{
MultiConnection *connection = (MultiConnection *) lfirst(connectionCell);
FinishConnectionEstablishment(connection);
}
/* the special BARE mode (for e.g. VACUUM/ANALYZE) skips BEGIN */ /* the special BARE mode (for e.g. VACUUM/ANALYZE) skips BEGIN */
if (MultiShardCommitProtocol > COMMIT_PROTOCOL_BARE) if (MultiShardCommitProtocol > COMMIT_PROTOCOL_BARE)