Home
last modified time | relevance | path

Searched refs:cfd (Results 1 – 4 of 4) sorted by relevance

/redis-3.2.3/src/
H A Dnetworking.c687 int cport, cfd, max = MAX_ACCEPTS_PER_CALL; in acceptTcpHandler() local
694 cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport); in acceptTcpHandler()
695 if (cfd == ANET_ERR) { in acceptTcpHandler()
702 acceptCommonHandler(cfd,0,cip); in acceptTcpHandler()
707 int cfd, max = MAX_ACCEPTS_PER_CALL; in acceptUnixHandler() local
713 cfd = anetUnixAccept(server.neterr, fd); in acceptUnixHandler()
714 if (cfd == ANET_ERR) { in acceptUnixHandler()
721 acceptCommonHandler(cfd,CLIENT_UNIX_SOCKET,NULL); in acceptUnixHandler()
H A Dcluster.c455 server.cfd,&server.cfd_count) == C_ERR) in clusterInit()
462 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
575 int cport, cfd; in clusterAcceptHandler() local
588 cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport); in clusterAcceptHandler()
589 if (cfd == ANET_ERR) { in clusterAcceptHandler()
595 anetNonBlock(NULL,cfd); in clusterAcceptHandler()
596 anetEnableTcpNoDelay(NULL,cfd); in clusterAcceptHandler()
606 link->fd = cfd; in clusterAcceptHandler()
607 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
H A Dserver.h734 int cfd[CONFIG_BINDADDR_MAX];/* Cluster bus listening socket */ member
H A Dserver.c2538 for (j = 0; j < server.cfd_count; j++) close(server.cfd[j]); in closeListeningSockets()