Lines Matching refs:fd
41 int fd = 0; in server_io_cb() local
43 fd = srvst->fds[idx].fd; in server_io_cb()
47 else if (!cb->read(cb->ptr, fd, events)) in server_io_cb()
54 else if (!cb->write(cb->ptr, fd, events)) in server_io_cb()
61 if (close(fd)) { in server_io_cb()
62 warn("server_io_cb: close(%d)", fd); in server_io_cb()
65 srvst->fds[idx].fd = -1; in server_io_cb()
71 struct sock_server_bind *serv, int fd, in server_add_state() argument
78 if (srvst->fds[n].fd == -1) { in server_add_state()
81 srvst->fds[n].fd = fd; in server_add_state()
99 srvst->fds[srvst->nfds].fd = fd; in server_add_state()
113 int fd = 0; in tcp_server_accept_cb() local
119 fd = accept(srvst->fds[idx].fd, sa, &len); in tcp_server_accept_cb()
120 if (fd == -1) { in tcp_server_accept_cb()
128 !srvst->cb->accept(srvst->cb->ptr, fd, &io_events)) { in tcp_server_accept_cb()
129 if (close(fd)) in tcp_server_accept_cb()
130 warn("server_accept_cb: close(%d)", fd); in tcp_server_accept_cb()
135 fd, io_events); in tcp_server_accept_cb()
145 return srvst->cb->accept(srvst->cb->ptr, srvst->fds[idx].fd, NULL); in udp_server_cb()
167 ts->bind[n].fd, POLLIN)) in sock_server()
204 if (srvst.fds[n].fd != -1 && srvst.socks[n].serv && in sock_server()
205 srvst.fds[n].fd != srvst.socks[n].serv->fd) { in sock_server()
206 if (close(srvst.fds[n].fd)) in sock_server()
207 warn("sock_server: close(%d)", srvst.fds[n].fd); in sock_server()
241 serv.fd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol); in sock_server_add_fd()
242 if (serv.fd < 0) in sock_server_add_fd()
245 if (bind(serv.fd, ai->ai_addr, ai->ai_addrlen)) in sock_server_add_fd()
248 if (ai->ai_socktype == SOCK_STREAM && listen(serv.fd, 5)) in sock_server_add_fd()
251 if (getsockname(serv.fd, sa, &len)) in sock_server_add_fd()
278 if (close(serv.fd)) in sock_server_add_fd()
279 warn("sock_server_add_fd: close(%d)", serv.fd); in sock_server_add_fd()
303 if (close(ts->bind[n].fd)) in sock_server_uninit()
304 warn("sock_server_uninit: close(%d)", ts->bind[n].fd); in sock_server_uninit()