| 2697 | } |
| 2698 | |
| 2699 | static void freeClusterManager(void) { |
| 2700 | listIter li; |
| 2701 | listNode *ln; |
| 2702 | if (cluster_manager.nodes != NULL) { |
| 2703 | listRewind(cluster_manager.nodes,&li); |
| 2704 | while ((ln = listNext(&li)) != NULL) { |
| 2705 | clusterManagerNode *n = ln->value; |
| 2706 | freeClusterManagerNode(n); |
| 2707 | } |
| 2708 | listRelease(cluster_manager.nodes); |
| 2709 | cluster_manager.nodes = NULL; |
| 2710 | } |
| 2711 | if (cluster_manager.errors != NULL) { |
| 2712 | listRewind(cluster_manager.errors,&li); |
| 2713 | while ((ln = listNext(&li)) != NULL) { |
| 2714 | sds err = ln->value; |
| 2715 | sdsfree(err); |
| 2716 | } |
| 2717 | listRelease(cluster_manager.errors); |
| 2718 | cluster_manager.errors = NULL; |
| 2719 | } |
| 2720 | if (clusterManagerUncoveredSlots != NULL) |
| 2721 | dictRelease(clusterManagerUncoveredSlots); |
| 2722 | } |
| 2723 | |
| 2724 | static clusterManagerNode *clusterManagerNewNode(char *ip, int port) { |
| 2725 | clusterManagerNode *node = zmalloc(sizeof(*node)); |
no test coverage detected