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

Tiny refactor to master_create_empty_shard

pull/1505/merge
Brian Cloutier 2017-07-12 12:38:37 +03:00 committed by Brian Cloutier
parent ee270b65d7
commit e6c375eb81
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/master/master_stage_protocol.c
View File

@ -70,7 +70,6 @@ master_create_empty_shard(PG_FUNCTION_ARGS)
{ {
text *relationNameText = PG_GETARG_TEXT_P(0); text *relationNameText = PG_GETARG_TEXT_P(0);
char *relationName = text_to_cstring(relationNameText); char *relationName = text_to_cstring(relationNameText);
List *workerNodeList = NIL;
uint64 shardId = INVALID_SHARD_ID; uint64 shardId = INVALID_SHARD_ID;
uint32 attemptableNodeCount = 0; uint32 attemptableNodeCount = 0;
uint32 liveNodeCount = 0; uint32 liveNodeCount = 0;
@ -88,8 +87,6 @@ master_create_empty_shard(PG_FUNCTION_ARGS)
CheckCitusVersion(ERROR); CheckCitusVersion(ERROR);
workerNodeList = ActiveWorkerNodeList();
EnsureTablePermissions(relationId, ACL_INSERT); EnsureTablePermissions(relationId, ACL_INSERT);
CheckDistributedTable(relationId); CheckDistributedTable(relationId);
@ -155,6 +152,7 @@ master_create_empty_shard(PG_FUNCTION_ARGS)
} }
else if (ShardPlacementPolicy == SHARD_PLACEMENT_ROUND_ROBIN) else if (ShardPlacementPolicy == SHARD_PLACEMENT_ROUND_ROBIN)
{ {
List *workerNodeList = ActiveWorkerNodeList();
candidateNode = WorkerGetRoundRobinCandidateNode(workerNodeList, shardId, candidateNode = WorkerGetRoundRobinCandidateNode(workerNodeList, shardId,
candidateNodeIndex); candidateNodeIndex);
} }