Home
last modified time | relevance | path

Searched refs:cport (Results 1 – 3 of 3) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dcluster.h138 int cport; /* Latest known cluster port of this node. */ member
194 uint16_t cport; /* cluster port last time it was seen */ member
270 uint16_t cport; /* Sender TCP cluster bus port */ member
H A Dcluster.c616 int cport, cfd; in clusterAcceptHandler() local
1268 node->cport == cport) break; in clusterHandshakeInProgress()
1301 if (port <= 0 || port > 65535 || cport <= 0 || cport > 65535) { in clusterStartHandshake()
1329 n->cport = cport; in clusterStartHandshake()
1413 node->cport != ntohs(g->cport))) in clusterProcessGossipSection()
1418 node->cport = ntohs(g->cport); in clusterProcessGossipSection()
1470 int cport = ntohs(hdr->cport); in nodeUpdateAddressIfNeeded() local
1481 if (node->port == port && node->cport == cport && in nodeUpdateAddressIfNeeded()
1487 node->cport = cport; in nodeUpdateAddressIfNeeded()
1773 node->cport = ntohs(hdr->cport); in clusterProcessPacket()
[all …]
H A Dnetworking.c735 int cport, cfd, max = MAX_ACCEPTS_PER_CALL; in acceptTcpHandler() local
742 cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport); in acceptTcpHandler()
749 serverLog(LL_VERBOSE,"Accepted %s:%d", cip, cport); in acceptTcpHandler()