171         n->port = atoi(p+1);  in clusterLoadConfig()
445     if (server.port > (65535-CLUSTER_PORT_INCR)) {  in clusterInit()
454     if (listenToPort(server.port+CLUSTER_PORT_INCR,  in clusterInit()
474     myself->port = server.port;  in clusterInit()
672     node->port = 0;  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
1257     if (port <= 0 || port > (65535-CLUSTER_PORT_INCR)) {  in clusterStartHandshake()
1274     if (clusterHandshakeInProgress(norm_ip,port)) {  in clusterStartHandshake()
1284     n->port = port;  in clusterStartHandshake()
1307             ntohs(g->port),  in clusterProcessGossipSection()
1341                 (strcasecmp(node->ip,g->ip) || node->port != ntohs(g->port)))  in clusterProcessGossipSection()
1345                 node->port = ntohs(g->port);  in clusterProcessGossipSection()
1359                 clusterStartHandshake(g->ip,ntohs(g->port));  in clusterProcessGossipSection()
1383 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, int port) {  in nodeUpdateAddressIfNeeded()  argument
1395     if (node->port == port && strcmp(ip,node->ip) == 0) return 0;  in nodeUpdateAddressIfNeeded()
1399     node->port = port;  in nodeUpdateAddressIfNeeded()
1403         node->name, node->ip, node->port);  in nodeUpdateAddressIfNeeded()
1408         replicationSetMaster(node->ip, node->port);  in nodeUpdateAddressIfNeeded()
1669             node->port = ntohs(hdr->port);  in clusterProcessPacket()
1699                     if (nodeUpdateAddressIfNeeded(sender,link,ntohs(hdr->port)))  in clusterProcessPacket()
1730                 link->node->port = 0;  in clusterProcessPacket()
1740             nodeUpdateAddressIfNeeded(sender,link,ntohs(hdr->port)))  in clusterProcessPacket()
2141     hdr->port = htons(server.port);  in clusterBuildMessageHdr()
2276         gossip->port = htons(this->port);  in clusterSendPing()
3103                 node->port+CLUSTER_PORT_INCR, NET_FIRST_BIND_ADDR);  in clusterCron()
3113                     node->port+CLUSTER_PORT_INCR,  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()
3703         node->port);  in clusterGenNodeDescription()
3857                 addReplyLongLong(c, node->port);  in clusterReplyMultiBulkSlots()
3867                     addReplyLongLong(c, node->slaves[i]->port);  in clusterReplyMultiBulkSlots()
3887         long long port;  in clusterCommand()  local
3889         if (getLongLongFromObject(c->argv[3], &port) != C_OK) {  in clusterCommand()
3895         if (clusterStartHandshake(c->argv[2]->ptr,port) == 0 &&  in clusterCommand()
4554 migrateCachedSocket* migrateGetSocket(client *c, robj *host, robj *port, long timeout) {  in migrateGetSocket()  argument
4562     name = sdscatlen(name,port->ptr,sdslen(port->ptr));  in migrateGetSocket()
4610 void migrateCloseSocket(robj *host, robj *port) {  in migrateCloseSocket()  argument
4616     name = sdscatlen(name,port->ptr,sdslen(port->ptr));  in migrateCloseSocket()
5162             hashslot,n->ip,n->port));  in clusterRedirectClient()