Lines Matching refs:replicate

1915     sds replicate;  /* Master ID if node is a slave */  member
2129 if (node->replicate != NULL) sdsfree(node->replicate); in freeClusterManagerNode()
2184 node->replicate = NULL; in clusterManagerNewNode()
2448 sds key = (!node->replicate ? node->name : node->replicate); in clusterManagerGetAntiAffinityScore()
2455 if (!node->replicate) types = sdscatprintf(types, "m%s", types); in clusterManagerGetAntiAffinityScore()
2477 if (n->replicate == NULL) continue; in clusterManagerGetAntiAffinityScore()
2478 if (!strcmp(n->replicate, name) && !strcmp(n->ip, ip)) { in clusterManagerGetAntiAffinityScore()
2529 if (n != first && n->replicate != NULL) in clusterManagerOptimizeAntiAffinity()
2538 char *first_master = first->replicate, in clusterManagerOptimizeAntiAffinity()
2539 *second_master = second->replicate; in clusterManagerOptimizeAntiAffinity()
2540 first->replicate = second_master, first->dirty = 1; in clusterManagerOptimizeAntiAffinity()
2541 second->replicate = first_master, second->dirty = 1; in clusterManagerOptimizeAntiAffinity()
2549 first->replicate = first_master; in clusterManagerOptimizeAntiAffinity()
2550 second->replicate = second_master; in clusterManagerOptimizeAntiAffinity()
2659 if (node->dirty && node->replicate != NULL) in clusterManagerNodeInfo()
2672 if (node->replicate != NULL) in clusterManagerNodeInfo()
2673 info = sdscatfmt(info, "\n%s replicates %S", spaces, node->replicate); in clusterManagerNodeInfo()
2715 if (n->replicate && !strcmp(n->replicate, node->name)) in clusterManagerShowClusterInfo()
3125 if (node->replicate != NULL) { in clusterManagerFlushNodeConfig()
3127 node->replicate); in clusterManagerFlushNodeConfig()
3325 if (currentNode->replicate) sdsfree(currentNode->replicate); in clusterManagerNodeLoadInfo()
3326 currentNode->replicate = sdsnew(master_id); in clusterManagerNodeLoadInfo()
3409 if (n->replicate != NULL) { in clusterManagerLoadInfoFromNode()
3410 clusterManagerNode *master = clusterManagerNodeByName(n->replicate); in clusterManagerLoadInfoFromNode()
3414 n->ip, n->port, n->replicate); in clusterManagerLoadInfoFromNode()
3617 if (n->flags & CLUSTER_MANAGER_FLAG_SLAVE || n->replicate) in clusterManagerGetNodeWithMostKeysInSlot()
3709 if (n->flags & CLUSTER_MANAGER_FLAG_SLAVE || n->replicate) in clusterManagerFixSlotsCoverage()
4732 if (slave->replicate) sdsfree(slave->replicate); in clusterManagerCommandCreate()
4733 slave->replicate = sdsnew(master->name); in clusterManagerCommandCreate()
4758 if (!flushed && node->dirty && !node->replicate) { in clusterManagerCommandCreate()
4819 if (!flushed && !node->replicate) { in clusterManagerCommandCreate()
4988 if (n->replicate && !strcasecmp(n->replicate, node_id)) { in clusterManagerCommandDeleteNode()
5171 if (n->flags & CLUSTER_MANAGER_FLAG_SLAVE || n->replicate) in clusterManagerCommandReshard()
5275 if (n->flags & CLUSTER_MANAGER_FLAG_SLAVE || n->replicate) in clusterManagerCommandRebalance()