Lines Matching refs:myself
48 clusterNode *myself = NULL; variable
179 serverAssert(server.cluster->myself == NULL); in clusterLoadConfig()
180 myself = server.cluster->myself = n; in clusterLoadConfig()
262 if (server.cluster->myself == NULL) goto fmterr; in clusterLoadConfig()
267 serverLog(LL_NOTICE,"Node configuration loaded, I'm %.40s", myself->name); in clusterLoadConfig()
402 server.cluster->myself = NULL; in clusterInit()
430 myself = server.cluster->myself = in clusterInit()
433 myself->name); in clusterInit()
434 clusterAddNode(myself); in clusterInit()
474 myself->port = server.port; in clusterInit()
495 if (nodeIsSlave(myself)) { in clusterReset()
496 clusterSetNodeAsMaster(myself); in clusterReset()
513 if (node == myself) continue; in clusterReset()
524 myself->configEpoch = 0; in clusterReset()
529 oldname = sdsnewlen(myself->name, CLUSTER_NAMELEN); in clusterReset()
532 getRandomHexChars(myself->name, CLUSTER_NAMELEN); in clusterReset()
533 clusterAddNode(myself); in clusterReset()
534 serverLog(LL_NOTICE,"Node hard reset, now I'm %.40s", myself->name); in clusterReset()
973 if (myself->configEpoch == 0 || in clusterBumpConfigEpochWithoutConsensus()
974 myself->configEpoch != maxEpoch) in clusterBumpConfigEpochWithoutConsensus()
977 myself->configEpoch = server.cluster->currentEpoch; in clusterBumpConfigEpochWithoutConsensus()
982 (unsigned long long) myself->configEpoch); in clusterBumpConfigEpochWithoutConsensus()
1037 if (sender->configEpoch != myself->configEpoch || in clusterHandleConfigEpochCollision()
1038 !nodeIsMaster(sender) || !nodeIsMaster(myself)) return; in clusterHandleConfigEpochCollision()
1040 if (memcmp(sender->name,myself->name,CLUSTER_NAMELEN) <= 0) return; in clusterHandleConfigEpochCollision()
1043 myself->configEpoch = server.cluster->currentEpoch; in clusterHandleConfigEpochCollision()
1049 (unsigned long long) myself->configEpoch); in clusterHandleConfigEpochCollision()
1160 if (nodeIsMaster(myself)) failures++; in markNodeAsFailingIfNeeded()
1173 if (nodeIsMaster(myself)) clusterSendFail(node->name); in markNodeAsFailingIfNeeded()
1316 if (sender && nodeIsMaster(sender) && node != myself) { in clusterProcessGossipSection()
1407 if (nodeIsSlave(myself) && myself->slaveof == node) in nodeUpdateAddressIfNeeded()
1420 if (n != myself) n->flags |= CLUSTER_NODE_MIGRATE_TO; in clusterSetNodeAsMaster()
1458 curmaster = nodeIsMaster(myself) ? myself : myself->slaveof; in clusterUpdateSlotsConfigWith()
1460 if (sender == myself) { in clusterUpdateSlotsConfigWith()
1485 if (server.cluster->slots[j] == myself && in clusterUpdateSlotsConfigWith()
1487 sender != myself) in clusterUpdateSlotsConfigWith()
1619 nodeIsSlave(myself) && in clusterProcessPacket()
1620 myself->slaveof == sender && in clusterProcessPacket()
1647 if (type == CLUSTERMSG_TYPE_MEET || myself->ip[0] == '\0') { in clusterProcessPacket()
1651 strcmp(ip,myself->ip)) in clusterProcessPacket()
1653 memcpy(myself->ip,ip,NET_IP_STR_LEN); in clusterProcessPacket()
1655 myself->ip); in clusterProcessPacket()
1875 nodeIsMaster(myself) && nodeIsMaster(sender) && in clusterProcessPacket()
1876 senderConfigEpoch == myself->configEpoch) 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()
2135 memcpy(hdr->sender,myself->name,CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2139 if (myself->slaveof != NULL) in clusterBuildMessageHdr()
2140 memcpy(hdr->slaveof,myself->slaveof->name, CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2142 hdr->flags = htons(myself->flags); in clusterBuildMessageHdr()
2150 if (nodeIsSlave(myself)) in clusterBuildMessageHdr()
2157 if (nodeIsMaster(myself) && server.cluster->mf_end) in clusterBuildMessageHdr()
2243 if (this == myself) continue; in clusterSendPing()
2318 if (node == myself || nodeInHandshake(node)) continue; in clusterBroadcastPong()
2322 (node->slaveof == myself || node->slaveof == myself->slaveof); in clusterBroadcastPong()
2478 if (nodeIsSlave(myself) || myself->numslots == 0) return; in clusterSendFailoverAuthIfNeeded()
2585 serverAssert(nodeIsSlave(myself)); in clusterGetSlaveRank()
2586 master = myself->slaveof; in clusterGetSlaveRank()
2591 if (master->slaves[j] != myself && 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()
2670 if (nodeIsMaster(myself) || oldmaster == NULL) return; in clusterFailoverReplaceYourMaster()
2673 clusterSetNodeAsMaster(myself); in clusterFailoverReplaceYourMaster()
2680 clusterAddSlot(myself,j); in clusterFailoverReplaceYourMaster()
2730 if (nodeIsMaster(myself) || in clusterHandleSlaveFailover()
2731 myself->slaveof == NULL || in clusterHandleSlaveFailover()
2732 (!nodeFailed(myself->slaveof) && !manual_failover) || in clusterHandleSlaveFailover()
2733 myself->slaveof->numslots == 0) in clusterHandleSlaveFailover()
2857 if (myself->configEpoch < server.cluster->failover_auth_epoch) { in clusterHandleSlaveFailover()
2858 myself->configEpoch = server.cluster->failover_auth_epoch; in clusterHandleSlaveFailover()
2861 (unsigned long long) myself->configEpoch); in clusterHandleSlaveFailover()
2900 clusterNode *mymaster = myself->slaveof, *target = NULL, *candidate = NULL; in clusterHandleSlaveMigration()
2925 candidate = myself; in clusterHandleSlaveMigration()
2973 if (target && candidate == myself && in clusterHandleSlaveMigration()
3197 if (nodeIsSlave(myself) && nodeIsMaster(node) && !nodeFailed(node)) { in clusterCron()
3209 if (nodeIsSlave(myself) && myself->slaveof == node) in clusterCron()
3243 nodeIsMaster(myself) && in clusterCron()
3275 if (nodeIsSlave(myself) && in clusterCron()
3277 myself->slaveof && in clusterCron()
3278 nodeHasAddr(myself->slaveof)) in clusterCron()
3280 replicationSetMaster(myself->slaveof->ip, myself->slaveof->port); in clusterCron()
3286 if (nodeIsSlave(myself)) { in clusterCron()
3485 if (nodeIsMaster(myself) && in clusterUpdateState()
3553 nodeIsMaster(myself) && in clusterUpdateState()
3594 if (nodeIsSlave(myself)) return C_OK; in verifyClusterConfigWithData()
3608 if (server.cluster->slots[j] == myself || in verifyClusterConfigWithData()
3620 clusterAddSlot(myself,j); in verifyClusterConfigWithData()
3639 serverAssert(n != myself); in clusterSetMaster()
3640 serverAssert(myself->numslots == 0); in clusterSetMaster()
3642 if (nodeIsMaster(myself)) { in clusterSetMaster()
3643 myself->flags &= ~(CLUSTER_NODE_MASTER|CLUSTER_NODE_MIGRATE_TO); in clusterSetMaster()
3644 myself->flags |= CLUSTER_NODE_SLAVE; in clusterSetMaster()
3647 if (myself->slaveof) in clusterSetMaster()
3648 clusterNodeRemoveSlave(myself->slaveof,myself); in clusterSetMaster()
3650 myself->slaveof = n; in clusterSetMaster()
3651 clusterNodeAddSlave(n,myself); in clusterSetMaster()
3913 addReplyBulkCBuffer(c,myself->name, CLUSTER_NAMELEN); in clusterCommand()
3923 clusterDelNodeSlots(myself); in clusterCommand()
3969 clusterAddSlot(myself,j); in clusterCommand()
3984 if (nodeIsSlave(myself)) { in clusterCommand()
3992 if (server.cluster->slots[slot] != myself) { in clusterCommand()
4003 if (server.cluster->slots[slot] == myself) { in clusterCommand()
4029 if (server.cluster->slots[slot] == myself && n != myself) { in clusterCommand()
4046 if (n == myself && in clusterCommand()
4078 (unsigned long long) myself->configEpoch); in clusterCommand()
4101 myepoch = (nodeIsSlave(myself) && myself->slaveof) ? in clusterCommand()
4102 myself->slaveof->configEpoch : myself->configEpoch; in clusterCommand()
4184 } else if (n == myself) { in clusterCommand()
4187 } else if (nodeIsSlave(myself) && myself->slaveof == n) { in clusterCommand()
4207 if (n == myself) { in clusterCommand()
4221 if (nodeIsMaster(myself) && in clusterCommand()
4222 (myself->numslots != 0 || dictSize(server.db[0].dict) != 0)) { in clusterCommand()
4286 if (nodeIsMaster(myself)) { 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()
4341 } else if (myself->configEpoch != 0) { in clusterCommand()
4344 myself->configEpoch = epoch; in clusterCommand()
4347 (unsigned long long) myself->configEpoch); in clusterCommand()
4378 if (nodeIsMaster(myself) && dictSize(c->db->dict) != 0) { in clusterCommand()
4990 if (!(c->flags & CLIENT_MULTI)) return myself; in getNodeByQuery()
5044 if (n == myself && in getNodeByQuery()
5081 if (n == NULL) return myself; in getNodeByQuery()
5096 return myself; in getNodeByQuery()
5116 return myself; in getNodeByQuery()
5125 nodeIsSlave(myself) && in getNodeByQuery()
5126 myself->slaveof == n) in getNodeByQuery()
5128 return myself; in getNodeByQuery()
5133 if (n != myself && error_code) *error_code = CLUSTER_REDIR_MOVED; in getNodeByQuery()
5199 if (node != myself && in clusterRedirectBlockedClientIfNeeded()