| 2430 | void freeClusterManager(void); |
| 2431 | |
| 2432 | static clusterManagerNode *clusterManagerNewNode(char *ip, int port) { |
| 2433 | clusterManagerNode *node = zmalloc(sizeof(*node), MALLOC_LOCAL); |
| 2434 | node->context = NULL; |
| 2435 | node->name = NULL; |
| 2436 | node->ip = ip; |
| 2437 | node->port = port; |
| 2438 | node->current_epoch = 0; |
| 2439 | node->ping_sent = 0; |
| 2440 | node->ping_recv = 0; |
| 2441 | node->flags = 0; |
| 2442 | node->flags_str = NULL; |
| 2443 | node->replicate = NULL; |
| 2444 | node->dirty = 0; |
| 2445 | node->friends = NULL; |
| 2446 | node->migrating = NULL; |
| 2447 | node->importing = NULL; |
| 2448 | node->migrating_count = 0; |
| 2449 | node->importing_count = 0; |
| 2450 | node->replicas_count = 0; |
| 2451 | node->weight = 1.0f; |
| 2452 | node->balance = 0; |
| 2453 | clusterManagerNodeResetSlots(node); |
| 2454 | return node; |
| 2455 | } |
| 2456 | |
| 2457 | static sds clusterManagerGetNodeRDBFilename(clusterManagerNode *node) { |
| 2458 | assert(config.cluster_manager_command.backup_dir); |
no test coverage detected