Lines Matching refs:ip
170 memcpy(n->ip,argv[1],strlen(argv[1])+1); in clusterLoadConfig()
671 memset(node->ip,0,sizeof(node->ip)); in createClusterNode()
1215 int clusterHandshakeInProgress(char *ip, int port) { in clusterHandshakeInProgress() argument
1224 if (!strcasecmp(node->ip,ip) && node->port == port) break; in clusterHandshakeInProgress()
1237 int clusterStartHandshake(char *ip, int port) { in clusterStartHandshake() argument
1243 if (inet_pton(AF_INET,ip, in clusterStartHandshake()
1247 } else if (inet_pton(AF_INET6,ip, in clusterStartHandshake()
1283 memcpy(n->ip,norm_ip,sizeof(n->ip)); in clusterStartHandshake()
1306 g->ip, in clusterProcessGossipSection()
1341 (strcasecmp(node->ip,g->ip) || node->port != ntohs(g->port))) in clusterProcessGossipSection()
1344 memcpy(node->ip,g->ip,NET_IP_STR_LEN); in clusterProcessGossipSection()
1359 clusterStartHandshake(g->ip,ntohs(g->port)); in clusterProcessGossipSection()
1384 char ip[NET_IP_STR_LEN] = {0}; in nodeUpdateAddressIfNeeded() local
1394 nodeIp2String(ip,link); in nodeUpdateAddressIfNeeded()
1395 if (node->port == port && strcmp(ip,node->ip) == 0) return 0; in nodeUpdateAddressIfNeeded()
1398 memcpy(node->ip,ip,sizeof(ip)); in nodeUpdateAddressIfNeeded()
1403 node->name, node->ip, node->port); in nodeUpdateAddressIfNeeded()
1408 replicationSetMaster(node->ip, node->port); in nodeUpdateAddressIfNeeded()
1647 if (type == CLUSTERMSG_TYPE_MEET || myself->ip[0] == '\0') { in clusterProcessPacket()
1648 char ip[NET_IP_STR_LEN]; in clusterProcessPacket() local
1650 if (anetSockName(link->fd,ip,sizeof(ip),NULL) != -1 && 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()
1668 nodeIp2String(node->ip,link); in clusterProcessPacket()
1729 link->node->ip[0] = '\0'; in clusterProcessPacket()
2275 memcpy(gossip->ip,this->ip,sizeof(this->ip)); in clusterSendPing()
3102 fd = anetTcpNonBlockBindConnect(server.neterr, node->ip, in clusterCron()
3112 "Cluster Node [%s]:%d -> %s", node->ip, in clusterCron()
3145 node->name, node->ip, node->port+CLUSTER_PORT_INCR); in clusterCron()
3280 replicationSetMaster(myself->slaveof->ip, myself->slaveof->port); in clusterCron()
3652 replicationSetMaster(n->ip, n->port); in clusterSetMaster()
3702 node->ip, in clusterGenNodeDescription()
3856 addReplyBulkCString(c, node->ip); in clusterReplyMultiBulkSlots()
3866 addReplyBulkCString(c, node->slaves[i]->ip); in clusterReplyMultiBulkSlots()
5162 hashslot,n->ip,n->port)); in clusterRedirectClient()