Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
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()
743 if (cfd == ANET_ERR) { in acceptTcpHandler()
750 acceptCommonHandler(cfd,0,cip); in acceptTcpHandler()
755 int cfd, max = MAX_ACCEPTS_PER_CALL; in acceptUnixHandler() local
761 cfd = anetUnixAccept(server.neterr, fd); in acceptUnixHandler()
762 if (cfd == ANET_ERR) { in acceptUnixHandler()
769 acceptCommonHandler(cfd,CLIENT_UNIX_SOCKET,NULL); in acceptUnixHandler()
H A Dcluster.c489 server.cfd,&server.cfd_count) == C_ERR) in clusterInit()
496 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
616 int cport, cfd; in clusterAcceptHandler() local
629 cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport); in clusterAcceptHandler()
630 if (cfd == ANET_ERR) { in clusterAcceptHandler()
636 anetNonBlock(NULL,cfd); in clusterAcceptHandler()
637 anetEnableTcpNoDelay(NULL,cfd); in clusterAcceptHandler()
647 link->fd = cfd; in clusterAcceptHandler()
648 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
H A Dserver.h977 int cfd[CONFIG_BINDADDR_MAX];/* Cluster bus listening socket */ member
H A Dserver.c2757 for (j = 0; j < server.cfd_count; j++) close(server.cfd[j]); in closeListeningSockets()
/f-stack/freebsd/contrib/openzfs/contrib/pyzfs/libzfs_core/test/
H A Dtest_libzfs_core.py2555 with cleanup_fd() as cfd:
2556 lzc.lzc_hold({dst3: b'tag'}, cfd)