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

Rename OpenConnectionsToAllNodes to OpenConnectionsToAllWorkerNodes

pull/3160/head
Philip Dubé 2019-11-05 21:16:27 +00:00 committed by Philip Dubé
parent 2fc45e5897
commit 72c3d64ead
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/master/citus_create_restore_point.c
View File

@ -30,7 +30,7 @@
/* local functions forward declarations */ /* local functions forward declarations */
static List * OpenConnectionsToAllNodes(LOCKMODE lockMode); static List * OpenConnectionsToAllWorkerNodes(LOCKMODE lockMode);
static void BlockDistributedTransactions(void); static void BlockDistributedTransactions(void);
static void CreateRemoteRestorePoints(char *restoreName, List *connectionList); static void CreateRemoteRestorePoints(char *restoreName, List *connectionList);
@ -87,7 +87,7 @@ citus_create_restore_point(PG_FUNCTION_ARGS)
* establish connections to all nodes before taking any locks * establish connections to all nodes before taking any locks
* ShareLock prevents new nodes being added, rendering connectionList incomplete * ShareLock prevents new nodes being added, rendering connectionList incomplete
*/ */
connectionList = OpenConnectionsToAllNodes(ShareLock); connectionList = OpenConnectionsToAllWorkerNodes(ShareLock);
/* /*
* Send a BEGIN to bust through pgbouncer. We won't actually commit since * Send a BEGIN to bust through pgbouncer. We won't actually commit since
@ -114,7 +114,7 @@ citus_create_restore_point(PG_FUNCTION_ARGS)
* of connections. * of connections.
*/ */
static List * static List *
OpenConnectionsToAllNodes(LOCKMODE lockMode) OpenConnectionsToAllWorkerNodes(LOCKMODE lockMode)
{ {
List *connectionList = NIL; List *connectionList = NIL;
List *workerNodeList = NIL; List *workerNodeList = NIL;