Lines Matching refs:slaves
666 node->slaves = NULL; in createClusterNode()
781 if (master->slaves[j] == slave) { in clusterNodeRemoveSlave()
784 memmove(master->slaves+j,master->slaves+(j+1), in clusterNodeRemoveSlave()
785 (sizeof(*master->slaves) * remaining_slaves)); in clusterNodeRemoveSlave()
801 if (master->slaves[j] == slave) return C_ERR; in clusterNodeAddSlave()
802 master->slaves = zrealloc(master->slaves, in clusterNodeAddSlave()
804 master->slaves[master->numslaves] = slave; in clusterNodeAddSlave()
814 if (!nodeFailed(n->slaves[j])) okslaves++; in clusterCountNonFailingSlaves()
826 n->slaves[j]->slaveof = NULL; in freeClusterNode()
839 zfree(n->slaves); in freeClusterNode()
2591 if (master->slaves[j] != myself && in clusterGetSlaveRank()
2592 master->slaves[j]->repl_offset > myoffset) rank++; in clusterGetSlaveRank()
2911 if (!nodeFailed(mymaster->slaves[j]) && in clusterHandleSlaveMigration()
2912 !nodeTimedOut(mymaster->slaves[j])) okslaves++; in clusterHandleSlaveMigration()
2957 if (memcmp(node->slaves[j]->name, in clusterHandleSlaveMigration()
2961 candidate = node->slaves[j]; in clusterHandleSlaveMigration()
3365 int slaves = 0; in clusterMastersHaveSlaves() local
3370 slaves += node->numslaves; in clusterMastersHaveSlaves()
3373 return slaves != 0; in clusterMastersHaveSlaves()
3864 if (nodeFailed(node->slaves[i])) continue; in clusterReplyMultiBulkSlots()
3866 addReplyBulkCString(c, node->slaves[i]->ip); in clusterReplyMultiBulkSlots()
3867 addReplyLongLong(c, node->slaves[i]->port); in clusterReplyMultiBulkSlots()
3868 addReplyBulkCBuffer(c, node->slaves[i]->name, CLUSTER_NAMELEN); in clusterReplyMultiBulkSlots()
4251 sds ni = clusterGenNodeDescription(n->slaves[j]); in clusterCommand()