Lines Matching refs:migrating

1921     sds *migrating; /* An array of sds where even strings are slots and odd  member
2133 if (node->migrating != NULL) { in freeClusterManagerNode()
2134 for (i = 0; i < node->migrating_count; i++) sdsfree(node->migrating[i]); in freeClusterManagerNode()
2135 zfree(node->migrating); in freeClusterManagerNode()
2187 node->migrating = NULL; in clusterManagerNewNode()
3237 node->migrating = zrealloc(node->migrating, in clusterManagerNodeLoadInfo()
3239 node->migrating[node->migrating_count - 2] = in clusterManagerNodeLoadInfo()
3241 node->migrating[node->migrating_count - 1] = in clusterManagerNodeLoadInfo()
3892 list *migrating = listCreate(); in clusterManagerFixOpenSlot() local
3924 if (n->migrating) { in clusterManagerFixOpenSlot()
3926 sds migrating_slot = n->migrating[i]; in clusterManagerFixOpenSlot()
3928 char *sep = (listLength(migrating) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
3931 listAddNodeTail(migrating, n); in clusterManagerFixOpenSlot()
4006 clusterManagerRemoveNodeFromList(migrating, owner); in clusterManagerFixOpenSlot()
4037 clusterManagerRemoveNodeFromList(migrating, n); in clusterManagerFixOpenSlot()
4043 if (listLength(migrating) == 1 && listLength(importing) == 1) { in clusterManagerFixOpenSlot()
4044 clusterManagerNode *src = listFirst(migrating)->value; in clusterManagerFixOpenSlot()
4056 else if (listLength(migrating) == 0 && listLength(importing) > 0) { in clusterManagerFixOpenSlot()
4091 else if (listLength(migrating) == 1 && listLength(importing) > 1) { in clusterManagerFixOpenSlot()
4093 clusterManagerNode *src = listFirst(migrating)->value; in clusterManagerFixOpenSlot()
4097 sds migrating_slot = src->migrating[i]; in clusterManagerFixOpenSlot()
4099 target_id = src->migrating[i + 1]; in clusterManagerFixOpenSlot()
4150 listLength(migrating) == 1); in clusterManagerFixOpenSlot()
4152 clusterManagerNode *n = listFirst(migrating)->value; in clusterManagerFixOpenSlot()
4169 clusterManagerNode *n = listFirst(migrating)->value; in clusterManagerFixOpenSlot()
4189 listRelease(migrating); in clusterManagerFixOpenSlot()
4260 if (n->migrating != NULL) { in clusterManagerCheckCluster()
4270 sds slot = n->migrating[i]; in clusterManagerCheckCluster()
4271 dictAdd(open_slots, slot, sdsdup(n->migrating[i + 1])); in clusterManagerCheckCluster()