Lines Matching refs:importing

1923     sds *importing; /* An array of sds where even strings are slots and odd  member
2137 if (node->importing != NULL) { in freeClusterManagerNode()
2138 for (i = 0; i < node->importing_count; i++) sdsfree(node->importing[i]); in freeClusterManagerNode()
2139 zfree(node->importing); in freeClusterManagerNode()
2188 node->importing = NULL; in clusterManagerNewNode()
3251 node->importing = zrealloc(node->importing, in clusterManagerNodeLoadInfo()
3253 node->importing[node->importing_count - 2] = in clusterManagerNodeLoadInfo()
3255 node->importing[node->importing_count - 1] = in clusterManagerNodeLoadInfo()
3893 list *importing = listCreate(); in clusterManagerFixOpenSlot() local
3937 if (!is_migrating && n->importing) { in clusterManagerFixOpenSlot()
3939 sds importing_slot = n->importing[i]; in clusterManagerFixOpenSlot()
3941 char *sep = (listLength(importing) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
3944 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
3961 char *sep = (listLength(importing) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
3964 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
4007 clusterManagerRemoveNodeFromList(importing, owner); in clusterManagerFixOpenSlot()
4034 clusterManagerRemoveNodeFromList(importing, n); in clusterManagerFixOpenSlot()
4035 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
4043 if (listLength(migrating) == 1 && listLength(importing) == 1) { in clusterManagerFixOpenSlot()
4045 clusterManagerNode *dst = listFirst(importing)->value; in clusterManagerFixOpenSlot()
4056 else if (listLength(migrating) == 0 && listLength(importing) > 0) { in clusterManagerFixOpenSlot()
4060 listRewind(importing, &li); in clusterManagerFixOpenSlot()
4091 else if (listLength(migrating) == 1 && listLength(importing) > 1) { in clusterManagerFixOpenSlot()
4106 listRewind(importing, &li); in clusterManagerFixOpenSlot()
4127 listRewind(importing, &li); in clusterManagerFixOpenSlot()
4141 listRewind(importing, &li); in clusterManagerFixOpenSlot()
4149 int try_to_close_slot = (listLength(importing) == 0 && in clusterManagerFixOpenSlot()
4190 listRelease(importing); in clusterManagerFixOpenSlot()
4278 if (n->importing != NULL) { in clusterManagerCheckCluster()
4288 sds slot = n->importing[i]; in clusterManagerCheckCluster()
4289 dictAdd(open_slots, slot, sdsdup(n->importing[i + 1])); in clusterManagerCheckCluster()