61 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave);
126         clusterNode *n, *master;  in clusterLoadConfig()  local
206             master = clusterLookupNode(argv[3]);  in clusterLoadConfig()
207             if (!master) {  in clusterLoadConfig()
208                 master = createClusterNode(argv[3],0);  in clusterLoadConfig()
209                 clusterAddNode(master);  in clusterLoadConfig()
211             n->slaveof = master;  in clusterLoadConfig()
212             clusterNodeAddSlave(master,n);  in clusterLoadConfig()
777 int clusterNodeRemoveSlave(clusterNode *master, clusterNode *slave) {  in clusterNodeRemoveSlave()  argument
780     for (j = 0; j < master->numslaves; j++) {  in clusterNodeRemoveSlave()
781         if (master->slaves[j] == slave) {  in clusterNodeRemoveSlave()
782             if ((j+1) < master->numslaves) {  in clusterNodeRemoveSlave()
783                 int remaining_slaves = (master->numslaves - j) - 1;  in clusterNodeRemoveSlave()
784                 memmove(master->slaves+j,master->slaves+(j+1),  in clusterNodeRemoveSlave()
785                         (sizeof(*master->slaves) * remaining_slaves));  in clusterNodeRemoveSlave()
787             master->numslaves--;  in clusterNodeRemoveSlave()
788             if (master->numslaves == 0)  in clusterNodeRemoveSlave()
789                 master->flags &= ~CLUSTER_NODE_MIGRATE_TO;  in clusterNodeRemoveSlave()
796 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave) {  in clusterNodeAddSlave()  argument
800     for (j = 0; j < master->numslaves; j++)  in clusterNodeAddSlave()
801         if (master->slaves[j] == slave) return C_ERR;  in clusterNodeAddSlave()
802     master->slaves = zrealloc(master->slaves,  in clusterNodeAddSlave()
803         sizeof(clusterNode*)*(master->numslaves+1));  in clusterNodeAddSlave()
804     master->slaves[master->numslaves] = slave;  in clusterNodeAddSlave()
805     master->numslaves++;  in clusterNodeAddSlave()
806     master->flags |= CLUSTER_NODE_MIGRATE_TO;  in clusterNodeAddSlave()
1775                 clusterNode *master = clusterLookupNode(hdr->slaveof);  in clusterProcessPacket()  local
1790                 if (master && sender->slaveof != master) {  in clusterProcessPacket()
1793                     clusterNodeAddSlave(master,sender);  in clusterProcessPacket()
1794                     sender->slaveof = master;  in clusterProcessPacket()
2119     clusterNode *master;  in clusterBuildMessageHdr()  local
2125     master = (nodeIsSlave(myself) && myself->slaveof) ?  in clusterBuildMessageHdr()
2137     memcpy(hdr->myslots,master->slots,sizeof(hdr->myslots));  in clusterBuildMessageHdr()
2147     hdr->configEpoch = htonu64(master->configEpoch);  in clusterBuildMessageHdr()
2467     clusterNode *master = node->slaveof;  in clusterSendFailoverAuthIfNeeded()  local
2505     if (nodeIsMaster(node) || master == NULL ||  in clusterSendFailoverAuthIfNeeded()
2506         (!nodeFailed(master) && !force_ack))  in clusterSendFailoverAuthIfNeeded()
2512         } else if (master == NULL) {  in clusterSendFailoverAuthIfNeeded()
2516         } else if (!nodeFailed(master)) {  in clusterSendFailoverAuthIfNeeded()
2583     clusterNode *master;  in clusterGetSlaveRank()  local
2586     master = myself->slaveof;  in clusterGetSlaveRank()
2587     if (master == NULL) return 0; /* Never called by slaves without master. */  in clusterGetSlaveRank()
2590     for (j = 0; j < master->numslaves; j++)  in clusterGetSlaveRank()
2591         if (master->slaves[j] != myself &&  in clusterGetSlaveRank()
2592             master->slaves[j]->repl_offset > myoffset) rank++;  in clusterGetSlaveRank()
2744         data_age = (mstime_t)(server.unixtime - server.master->lastinteraction)  in clusterHandleSlaveFailover()