Lines Matching refs:sender
692 int clusterNodeAddFailureReport(clusterNode *failing, clusterNode *sender) { in clusterNodeAddFailureReport() argument
703 if (fr->node == sender) { in clusterNodeAddFailureReport()
711 fr->node = sender; in clusterNodeAddFailureReport()
749 int clusterNodeDelFailureReport(clusterNode *node, clusterNode *sender) { in clusterNodeDelFailureReport() argument
759 if (fr->node == sender) break; in clusterNodeDelFailureReport()
1035 void clusterHandleConfigEpochCollision(clusterNode *sender) { in clusterHandleConfigEpochCollision() argument
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()
1048 sender->name, in clusterHandleConfigEpochCollision()
1296 clusterNode *sender = link->node ? link->node : clusterLookupNode(hdr->sender); in clusterProcessGossipSection() local
1316 if (sender && nodeIsMaster(sender) && node != myself) { in clusterProcessGossipSection()
1318 if (clusterNodeAddFailureReport(node,sender)) { in clusterProcessGossipSection()
1321 sender->name, node->name); in clusterProcessGossipSection()
1325 if (clusterNodeDelFailureReport(node,sender)) { in clusterProcessGossipSection()
1328 sender->name, node->name); in clusterProcessGossipSection()
1355 if (sender && in clusterProcessGossipSection()
1442 void clusterUpdateSlotsConfigWith(clusterNode *sender, uint64_t senderConfigEpoch, unsigned char *s… in clusterUpdateSlotsConfigWith() argument
1460 if (sender == myself) { in clusterUpdateSlotsConfigWith()
1468 if (server.cluster->slots[j] == sender) continue; in clusterUpdateSlotsConfigWith()
1487 sender != myself) in clusterUpdateSlotsConfigWith()
1494 newmaster = sender; in clusterUpdateSlotsConfigWith()
1496 clusterAddSlot(sender,j); in clusterUpdateSlotsConfigWith()
1514 "as a replica of %.40s", sender->name); in clusterUpdateSlotsConfigWith()
1515 clusterSetMaster(sender); in clusterUpdateSlotsConfigWith()
1561 clusterNode *sender; in clusterProcessPacket() local
1600 sender = clusterLookupNode(hdr->sender); in clusterProcessPacket()
1601 if (sender && !nodeInHandshake(sender)) { in clusterProcessPacket()
1608 if (senderConfigEpoch > sender->configEpoch) { in clusterProcessPacket()
1609 sender->configEpoch = senderConfigEpoch; in clusterProcessPacket()
1614 sender->repl_offset = ntohu64(hdr->offset); in clusterProcessPacket()
1615 sender->repl_offset_time = mstime(); in clusterProcessPacket()
1620 myself->slaveof == sender && in clusterProcessPacket()
1624 server.cluster->mf_master_offset = sender->repl_offset; in clusterProcessPacket()
1664 if (!sender && type == CLUSTERMSG_TYPE_MEET) { in clusterProcessPacket()
1677 if (!sender && type == CLUSTERMSG_TYPE_MEET) in clusterProcessPacket()
1695 if (sender) { in clusterProcessPacket()
1698 "updating the address if needed.", sender->name); in clusterProcessPacket()
1699 if (nodeUpdateAddressIfNeeded(sender,link,ntohs(hdr->port))) in clusterProcessPacket()
1712 clusterRenameNode(link->node, hdr->sender); in clusterProcessPacket()
1718 } else if (memcmp(link->node->name,hdr->sender, in clusterProcessPacket()
1738 if (sender && type == CLUSTERMSG_TYPE_PING && in clusterProcessPacket()
1739 !nodeInHandshake(sender) && in clusterProcessPacket()
1740 nodeUpdateAddressIfNeeded(sender,link,ntohs(hdr->port))) in clusterProcessPacket()
1767 if (sender) { in clusterProcessPacket()
1772 clusterSetNodeAsMaster(sender); in clusterProcessPacket()
1777 if (nodeIsMaster(sender)) { in clusterProcessPacket()
1779 clusterDelNodeSlots(sender); in clusterProcessPacket()
1780 sender->flags &= ~(CLUSTER_NODE_MASTER| in clusterProcessPacket()
1782 sender->flags |= CLUSTER_NODE_SLAVE; in clusterProcessPacket()
1790 if (master && sender->slaveof != master) { in clusterProcessPacket()
1791 if (sender->slaveof) in clusterProcessPacket()
1792 clusterNodeRemoveSlave(sender->slaveof,sender); in clusterProcessPacket()
1793 clusterNodeAddSlave(master,sender); in clusterProcessPacket()
1794 sender->slaveof = master; in clusterProcessPacket()
1814 if (sender) { in clusterProcessPacket()
1815 sender_master = nodeIsMaster(sender) ? sender : sender->slaveof; in clusterProcessPacket()
1825 if (sender && nodeIsMaster(sender) && dirty_slots) in clusterProcessPacket()
1826 clusterUpdateSlotsConfigWith(sender,senderConfigEpoch,hdr->myslots); in clusterProcessPacket()
1846 if (sender && dirty_slots) { in clusterProcessPacket()
1851 if (server.cluster->slots[j] == sender || in clusterProcessPacket()
1859 sender->name, server.cluster->slots[j]->name); in clusterProcessPacket()
1860 clusterSendUpdate(sender->link, in clusterProcessPacket()
1874 if (sender && in clusterProcessPacket()
1875 nodeIsMaster(myself) && nodeIsMaster(sender) && in clusterProcessPacket()
1878 clusterHandleConfigEpochCollision(sender); in clusterProcessPacket()
1882 if (sender) clusterProcessGossipSection(hdr,link); in clusterProcessPacket()
1886 if (sender) { in clusterProcessPacket()
1893 hdr->sender, hdr->data.fail.about.nodename); in clusterProcessPacket()
1903 hdr->sender, hdr->data.fail.about.nodename); in clusterProcessPacket()
1926 if (!sender) return 1; /* We don't know that node. */ in clusterProcessPacket()
1927 clusterSendFailoverAuthIfNeeded(sender,hdr); in clusterProcessPacket()
1929 if (!sender) return 1; /* We don't know that node. */ in clusterProcessPacket()
1933 if (nodeIsMaster(sender) && sender->numslots > 0 && in clusterProcessPacket()
1944 if (!sender || sender->slaveof != myself) return 1; in clusterProcessPacket()
1949 server.cluster->mf_slave = sender; in clusterProcessPacket()
1952 sender->name); in clusterProcessPacket()
1958 if (!sender) return 1; /* We don't know the sender. */ in clusterProcessPacket()
2135 memcpy(hdr->sender,myself->name,CLUSTER_NAMELEN); in clusterBuildMessageHdr()