Lines Matching refs:slaveof
211 n->slaveof = master; in clusterLoadConfig()
667 node->slaveof = NULL; in createClusterNode()
826 n->slaves[j]->slaveof = NULL; in freeClusterNode()
829 if (nodeIsSlave(n) && n->slaveof) clusterNodeRemoveSlave(n->slaveof,n); in freeClusterNode()
1407 if (nodeIsSlave(myself) && myself->slaveof == node) in nodeUpdateAddressIfNeeded()
1418 if (n->slaveof) { in clusterSetNodeAsMaster()
1419 clusterNodeRemoveSlave(n->slaveof,n); in clusterSetNodeAsMaster()
1424 n->slaveof = NULL; in clusterSetNodeAsMaster()
1458 curmaster = nodeIsMaster(myself) ? myself : myself->slaveof; in clusterUpdateSlotsConfigWith()
1620 myself->slaveof == sender && in clusterProcessPacket()
1768 if (!memcmp(hdr->slaveof,CLUSTER_NODE_NULL_NAME, in clusterProcessPacket()
1769 sizeof(hdr->slaveof))) in clusterProcessPacket()
1775 clusterNode *master = clusterLookupNode(hdr->slaveof); in clusterProcessPacket()
1790 if (master && sender->slaveof != master) { in clusterProcessPacket()
1791 if (sender->slaveof) in clusterProcessPacket()
1792 clusterNodeRemoveSlave(sender->slaveof,sender); in clusterProcessPacket()
1794 sender->slaveof = master; in clusterProcessPacket()
1815 sender_master = nodeIsMaster(sender) ? sender : sender->slaveof; in clusterProcessPacket()
1944 if (!sender || sender->slaveof != myself) return 1; in clusterProcessPacket()
2125 master = (nodeIsSlave(myself) && myself->slaveof) ? in clusterBuildMessageHdr()
2126 myself->slaveof : myself; in clusterBuildMessageHdr()
2138 memset(hdr->slaveof,0,CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2139 if (myself->slaveof != NULL) in clusterBuildMessageHdr()
2140 memcpy(hdr->slaveof,myself->slaveof->name, CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2321 nodeIsSlave(node) && node->slaveof && in clusterBroadcastPong()
2322 (node->slaveof == myself || node->slaveof == myself->slaveof); in clusterBroadcastPong()
2467 clusterNode *master = node->slaveof; in clusterSendFailoverAuthIfNeeded()
2527 if (mstime() - node->slaveof->voted_time < server.cluster_node_timeout * 2) in clusterSendFailoverAuthIfNeeded()
2534 (mstime() - node->slaveof->voted_time))); in clusterSendFailoverAuthIfNeeded()
2563 node->slaveof->voted_time = mstime(); in clusterSendFailoverAuthIfNeeded()
2586 master = myself->slaveof; in clusterGetSlaveRank()
2633 if (myself->slaveof && in clusterLogCantFailover()
2634 nodeFailed(myself->slaveof) && in clusterLogCantFailover()
2635 (mstime() - myself->slaveof->fail_time) < nolog_fail_time) return; in clusterLogCantFailover()
2668 clusterNode *oldmaster = myself->slaveof; in clusterFailoverReplaceYourMaster()
2731 myself->slaveof == NULL || in clusterHandleSlaveFailover()
2732 (!nodeFailed(myself->slaveof) && !manual_failover) || in clusterHandleSlaveFailover()
2733 myself->slaveof->numslots == 0) in clusterHandleSlaveFailover()
2900 clusterNode *mymaster = myself->slaveof, *target = NULL, *candidate = NULL; in clusterHandleSlaveMigration()
3209 if (nodeIsSlave(myself) && myself->slaveof == node) in clusterCron()
3277 myself->slaveof && in clusterCron()
3278 nodeHasAddr(myself->slaveof)) in clusterCron()
3280 replicationSetMaster(myself->slaveof->ip, myself->slaveof->port); in clusterCron()
3647 if (myself->slaveof) in clusterSetMaster()
3648 clusterNodeRemoveSlave(myself->slaveof,myself); in clusterSetMaster()
3650 myself->slaveof = n; in clusterSetMaster()
3709 if (node->slaveof) in clusterGenNodeDescription()
3710 ci = sdscatprintf(ci," %.40s ",node->slaveof->name); in clusterGenNodeDescription()
4101 myepoch = (nodeIsSlave(myself) && myself->slaveof) ? in clusterCommand()
4102 myself->slaveof->configEpoch : myself->configEpoch; in clusterCommand()
4187 } else if (nodeIsSlave(myself) && myself->slaveof == n) { in clusterCommand()
4289 } else if (myself->slaveof == NULL) { in clusterCommand()
4293 (nodeFailed(myself->slaveof) || in clusterCommand()
4294 myself->slaveof->link == NULL)) in clusterCommand()
4319 clusterSendMFStart(myself->slaveof); in clusterCommand()
5126 myself->slaveof == n) in getNodeByQuery()