diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index aac0f0155..8e092bdfd 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -134,7 +134,8 @@ static void MarkNodesNotSyncedInLoopBackConnection(MetadataSyncContext *context, static void EnsureParentSessionHasExclusiveLockOnPgDistNode(pid_t parentSessionPid); static void SetNodeMetadata(MetadataSyncContext *context, bool localOnly); static void EnsureTransactionalMetadataSyncMode(void); -static void lock_shards_in_worker_placement_list(WorkerNode *workerNode, LOCKMODE lockMode); +static void lock_shards_in_worker_placement_list(WorkerNode *workerNode, LOCKMODE + lockMode); /* declarations for dynamic loading */ PG_FUNCTION_INFO_V1(citus_set_coordinator_host); @@ -1161,16 +1162,20 @@ ActivateNodeList(MetadataSyncContext *context) SetNodeMetadata(context, localOnly); } + /* -* Adds locks into all shards placed into given workerNode. -*/ -void lock_shards_in_worker_placement_list(WorkerNode *workerNode , LOCKMODE lockMode){ + * Adds locks into all shards placed into given workerNode. + */ +void +lock_shards_in_worker_placement_list(WorkerNode *workerNode, LOCKMODE lockMode) +{ List *placementList = NIL; placementList = AllShardPlacementsOnNodeGroup(workerNode->groupId); LockShardsInPlacementListMetadata(placementList, lockMode); } + /* * citus_update_node moves the requested node to a different nodename and nodeport. It * locks to ensure no queries are running concurrently; and is intended for customers who @@ -1339,8 +1344,6 @@ citus_update_node(PG_FUNCTION_ARGS) } - - Datum citus_pause_node_within_txn(PG_FUNCTION_ARGS) {