mirror of https://github.com/citusdata/citus.git
parent
2cf172fd27
commit
3aee6aa494
|
@ -318,20 +318,6 @@ ActivePrimaryNodeCount(void)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/*
|
|
||||||
* ActiveReadableNonCoordinatorNodeCount returns the number of groups with a node we can read from.
|
|
||||||
* This method excludes coordinator even if it is added as a worker.
|
|
||||||
*/
|
|
||||||
uint32
|
|
||||||
ActiveReadableNonCoordinatorNodeCount(void)
|
|
||||||
{
|
|
||||||
List *workerNodeList = ActiveReadableNonCoordinatorNodeList();
|
|
||||||
uint32 liveWorkerCount = list_length(workerNodeList);
|
|
||||||
|
|
||||||
return liveWorkerCount;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* NodeIsCoordinator returns true if the given node represents the coordinator.
|
* NodeIsCoordinator returns true if the given node represents the coordinator.
|
||||||
*/
|
*/
|
||||||
|
|
|
@ -80,7 +80,6 @@ extern WorkerNode * CoordinatorNodeIfAddedAsWorkerOrError(void);
|
||||||
extern void ErrorIfCoordinatorNotAddedAsWorkerNode(void);
|
extern void ErrorIfCoordinatorNotAddedAsWorkerNode(void);
|
||||||
extern List * DistributedTablePlacementNodeList(LOCKMODE lockMode);
|
extern List * DistributedTablePlacementNodeList(LOCKMODE lockMode);
|
||||||
extern bool NodeCanHaveDistTablePlacements(WorkerNode *node);
|
extern bool NodeCanHaveDistTablePlacements(WorkerNode *node);
|
||||||
extern uint32 ActiveReadableNonCoordinatorNodeCount(void);
|
|
||||||
extern List * ActiveReadableNonCoordinatorNodeList(void);
|
extern List * ActiveReadableNonCoordinatorNodeList(void);
|
||||||
extern List * ActiveReadableNodeList(void);
|
extern List * ActiveReadableNodeList(void);
|
||||||
extern WorkerNode * FindWorkerNode(const char *nodeName, int32 nodePort);
|
extern WorkerNode * FindWorkerNode(const char *nodeName, int32 nodePort);
|
||||||
|
|
Loading…
Reference in New Issue