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

Make NodeCanHaveDistTablePlacements() public (#3229) 

Since it is required in rebalancer.
pull/3317/head
Önder Kalacı 2019-11-26 12:15:38 +01:00 committed by Marco Slot
parent cd64bd5c80
commit 66ee548c20
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/master/worker_node_manager.c
View File

@ -45,7 +45,6 @@ static WorkerNode * FindRandomNodeFromList(List *candidateWorkerNodeList);
static bool OddNumber(uint32 number); static bool OddNumber(uint32 number);
static bool ListMember(List *currentList, WorkerNode *workerNode); static bool ListMember(List *currentList, WorkerNode *workerNode);
static bool NodeIsPrimaryWorker(WorkerNode *node); static bool NodeIsPrimaryWorker(WorkerNode *node);
static bool NodeCanHaveDistTablePlacements(WorkerNode *node);
static bool NodeIsReadableWorker(WorkerNode *node); static bool NodeIsReadableWorker(WorkerNode *node);
@ -430,7 +429,7 @@ DistributedTablePlacementNodeList(LOCKMODE lockMode)
* NodeCanHaveDistTablePlacements returns true if the given node can have * NodeCanHaveDistTablePlacements returns true if the given node can have
* shards of a distributed table. * shards of a distributed table.
*/ */
static bool bool
NodeCanHaveDistTablePlacements(WorkerNode *node) NodeCanHaveDistTablePlacements(WorkerNode *node)
{ {
if (!NodeIsPrimary(node)) if (!NodeIsPrimary(node))

1
src/include/distributed/worker_manager.h
View File

@ -74,6 +74,7 @@ extern List * ActivePrimaryWorkerNodeList(LOCKMODE lockMode);
extern List * ActivePrimaryNodeList(LOCKMODE lockMode); extern List * ActivePrimaryNodeList(LOCKMODE lockMode);
extern List * ReferenceTablePlacementNodeList(LOCKMODE lockMode); extern List * ReferenceTablePlacementNodeList(LOCKMODE lockMode);
extern List * DistributedTablePlacementNodeList(LOCKMODE lockMode); extern List * DistributedTablePlacementNodeList(LOCKMODE lockMode);
extern bool NodeCanHaveDistTablePlacements(WorkerNode *node);
extern uint32 ActiveReadableWorkerNodeCount(void); extern uint32 ActiveReadableWorkerNodeCount(void);
extern List * ActiveReadableWorkerNodeList(void); extern List * ActiveReadableWorkerNodeList(void);
extern List * ActiveReadableNodeList(void); extern List * ActiveReadableNodeList(void);