From 0620d62373b006a61c2536142eaf5bd94628925e Mon Sep 17 00:00:00 2001 From: EmelSimsek Date: Fri, 8 Mar 2024 14:54:42 +0300 Subject: [PATCH] Reindent --- .../utils/multi_partitioning_utils.c | 22 ++++++++++--------- src/include/distributed/shard_rebalancer.h | 2 +- 2 files changed, 13 insertions(+), 11 deletions(-) diff --git a/src/backend/distributed/utils/multi_partitioning_utils.c b/src/backend/distributed/utils/multi_partitioning_utils.c index e034e276b..13ecdab68 100644 --- a/src/backend/distributed/utils/multi_partitioning_utils.c +++ b/src/backend/distributed/utils/multi_partitioning_utils.c @@ -50,7 +50,7 @@ #include "distributed/version_compat.h" #include "distributed/worker_protocol.h" -extern List *FullShardPlacementList(Oid relationId, ArrayType *excludedShardArray); +extern List * FullShardPlacementList(Oid relationId, ArrayType *excludedShardArray); static char * PartitionBound(Oid partitionId); static Relation try_relation_open_nolock(Oid relationId); static List * CreateFixPartitionConstraintsTaskList(Oid relationId); @@ -558,24 +558,26 @@ CreateFixPartitionShardIndexNames(Oid parentRelationId, Oid partitionRelationId, int taskId = 1; - List *shardPlacementList = FullShardPlacementList(parentRelationId, construct_empty_array(INT4OID)); + List *shardPlacementList = FullShardPlacementList(parentRelationId, + construct_empty_array(INT4OID)); + - List *workerNodeList = ReadDistNode(true); /* make sure we have deterministic output for our tests */ workerNodeList = SortList(workerNodeList, CompareWorkerNodes); - MemoryContext localContext = AllocSetContextCreate(CurrentMemoryContext, "CreateFixPartitionShardIndexNames", - ALLOCSET_DEFAULT_SIZES); - MemoryContext oldContext = MemoryContextSwitchTo(localContext); + MemoryContext localContext = AllocSetContextCreate(CurrentMemoryContext, + "CreateFixPartitionShardIndexNames", + ALLOCSET_DEFAULT_SIZES); + MemoryContext oldContext = MemoryContextSwitchTo(localContext); WorkerNode *workerNode = NULL; foreach_ptr(workerNode, workerNodeList) { List *shardsOnNode = FilterActiveShardPlacementListByNode( - shardPlacementList, workerNode); - + shardPlacementList, workerNode); + ShardPlacement *shardPlacement = NULL; foreach_ptr(shardPlacement, shardsOnNode) @@ -584,8 +586,8 @@ CreateFixPartitionShardIndexNames(Oid parentRelationId, Oid partitionRelationId, List *queryStringList = WorkerFixPartitionShardIndexNamesCommandList(parentShardId, - parentIndexIdList, - partitionRelationId); + parentIndexIdList, + partitionRelationId); if (queryStringList != NIL) { Task *task = CitusMakeNode(Task); diff --git a/src/include/distributed/shard_rebalancer.h b/src/include/distributed/shard_rebalancer.h index f6f555677..16d12728c 100644 --- a/src/include/distributed/shard_rebalancer.h +++ b/src/include/distributed/shard_rebalancer.h @@ -222,6 +222,6 @@ extern void SetupRebalanceMonitor(List *placementUpdateList, uint64 initialProgressState, PlacementUpdateStatus initialStatus); -extern List *FullShardPlacementList(Oid relationId, ArrayType *excludedShardArray); +extern List * FullShardPlacementList(Oid relationId, ArrayType *excludedShardArray); #endif /* SHARD_REBALANCER_H */