diff --git a/src/backend/distributed/master/worker_node_manager.c b/src/backend/distributed/master/worker_node_manager.c index 70d28d383..a1daddb11 100644 --- a/src/backend/distributed/master/worker_node_manager.c +++ b/src/backend/distributed/master/worker_node_manager.c @@ -41,7 +41,6 @@ static WorkerNode * FindRandomNodeNotInList(HTAB *WorkerNodesHash, List *currentNodeList); static bool OddNumber(uint32 number); static bool ListMember(List *currentList, WorkerNode *workerNode); -static bool WorkerNodeResponsive(const char *workerName, uint32 workerPort); /* ------------------------------------------------------------ @@ -478,52 +477,3 @@ WorkerNodeCompare(const void *lhsKey, const void *rhsKey, Size keySize) portCompare = workerLhs->workerPort - workerRhs->workerPort; return portCompare; } - - -/* ResponsiveWorkerNodeList returns a list of all responsive worker nodes */ -List * -ResponsiveWorkerNodeList(void) -{ - List *responsiveWorkerNodeList = NULL; - ListCell *workerNodeCell = NULL; - List *workerNodeList = WorkerNodeList(); - - foreach(workerNodeCell, workerNodeList) - { - bool workerNodeResponsive = false; - WorkerNode *workerNode = lfirst(workerNodeCell); - - workerNodeResponsive = WorkerNodeResponsive(workerNode->workerName, - workerNode->workerPort); - if (workerNodeResponsive) - { - responsiveWorkerNodeList = lappend(responsiveWorkerNodeList, workerNode); - } - } - - return responsiveWorkerNodeList; -} - - -/* - * WorkerNodeResponsive returns true if the given worker node is reponsive. - * Otherwise, it returns false. - * - * This function is based on worker_node_responsive function present in the - * shard rebalancer. - */ -static bool -WorkerNodeResponsive(const char *workerName, uint32 workerPort) -{ - bool workerNodeResponsive = false; - - int connectionId = MultiClientConnect(workerName, workerPort, NULL, NULL); - if (connectionId != INVALID_CONNECTION_ID) - { - MultiClientDisconnect(connectionId); - - workerNodeResponsive = true; - } - - return workerNodeResponsive; -} diff --git a/src/include/distributed/worker_manager.h b/src/include/distributed/worker_manager.h index 7f832d3b3..9590860d5 100644 --- a/src/include/distributed/worker_manager.h +++ b/src/include/distributed/worker_manager.h @@ -60,7 +60,6 @@ extern WorkerNode * WorkerGetLocalFirstCandidateNode(List *currentNodeList); extern WorkerNode * WorkerGetNodeWithName(const char *hostname); extern uint32 WorkerGetLiveNodeCount(void); extern List * WorkerNodeList(void); -extern List * ResponsiveWorkerNodeList(void); extern WorkerNode * FindWorkerNode(char *nodeName, int32 nodePort); extern List * ReadWorkerNodes(void);