| 946 | } |
| 947 | |
| 948 | int clusterNodeRemoveSlave(clusterNode *master, clusterNode *slave) { |
| 949 | int j; |
| 950 | |
| 951 | for (j = 0; j < master->numslaves; j++) { |
| 952 | if (master->slaves[j] == slave) { |
| 953 | if ((j+1) < master->numslaves) { |
| 954 | int remaining_slaves = (master->numslaves - j) - 1; |
| 955 | memmove(master->slaves+j,master->slaves+(j+1), |
| 956 | (sizeof(*master->slaves) * remaining_slaves)); |
| 957 | } |
| 958 | master->numslaves--; |
| 959 | if (master->numslaves == 0) |
| 960 | master->flags &= ~CLUSTER_NODE_MIGRATE_TO; |
| 961 | return C_OK; |
| 962 | } |
| 963 | } |
| 964 | return C_ERR; |
| 965 | } |
| 966 | |
| 967 | int clusterNodeAddSlave(clusterNode *master, clusterNode *slave) { |
| 968 | int j; |
no outgoing calls
no test coverage detected