Lines Matching refs:new_node
4891 clusterManagerNode *new_node = clusterManagerNewNode(ip, port); in clusterManagerCommandAddNode() local
4893 if (!clusterManagerNodeConnect(new_node)) { in clusterManagerCommandAddNode()
4900 if (!(success = clusterManagerNodeIsCluster(new_node, &err))) { in clusterManagerCommandAddNode()
4901 clusterManagerPrintNotClusterNodeError(new_node, err); in clusterManagerCommandAddNode()
4905 if (!clusterManagerNodeLoadInfo(new_node, 0, &err)) { in clusterManagerCommandAddNode()
4907 CLUSTER_MANAGER_PRINT_REPLY_ERROR(new_node, err); in clusterManagerCommandAddNode()
4913 if (!(success = clusterManagerNodeIsEmpty(new_node, &err))) { in clusterManagerCommandAddNode()
4914 clusterManagerPrintNotEmptyNodeError(new_node, err); in clusterManagerCommandAddNode()
4919 listAddNodeTail(cluster_manager.nodes, new_node); in clusterManagerCommandAddNode()
4925 reply = CLUSTER_MANAGER_COMMAND(new_node, "CLUSTER MEET %s %d", in clusterManagerCommandAddNode()
4927 if (!(success = clusterManagerCheckRedisReply(new_node, reply, NULL))) in clusterManagerCommandAddNode()
4937 reply = CLUSTER_MANAGER_COMMAND(new_node, "CLUSTER REPLICATE %s", in clusterManagerCommandAddNode()
4939 if (!(success = clusterManagerCheckRedisReply(new_node, reply, NULL))) in clusterManagerCommandAddNode()
4944 if (!added && new_node) freeClusterManagerNode(new_node); in clusterManagerCommandAddNode()