Lines Matching refs:fd

63 				srv_socket->fd,  in network_server_handle_fdevent()
145 	int fd;  local
174 	srv_socket->fd = -1;
222 		if (-1 == (srv_socket->fd = socket(srv_socket->addr.plain.sa_family, SOCK_STREAM, 0))) {
235 	srv_socket->fd = mtcp_socket(srv->mctx, AF_INET, SOCK_STREAM, 0);
236 	if (srv_socket->fd < 0) {
240 	if (mtcp_setsock_nonblock(srv->mctx, srv_socket->fd) < 0) {
248 	if (srv_socket->fd == -1 && srv_socket->use_ipv6) {
251 		if (-1 == (srv_socket->fd = socket(srv_socket->addr.plain.sa_family, SOCK_STREAM, IPPROTO_TCP))) {
259 	if (srv_socket->fd == -1) {
261 		if (-1 == (srv_socket->fd = socket(srv_socket->addr.plain.sa_family, SOCK_STREAM, IPPROTO_TCP))) {
270 	fcntl(srv_socket->fd, F_SETFD, FD_CLOEXEC);
273 	if (setsockopt(srv_socket->fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)) < 0) {
280 	srv->cur_fds = srv_socket->fd;
296 				if (-1 == setsockopt(srv_socket->fd, IPPROTO_IPV6, IPV6_V6ONLY, &val, sizeof(val))) {
369 		if (-1 != (fd = connect(srv_socket->fd, (struct sockaddr *) &(srv_socket->addr), addr_len))) {
370 			close(fd);
401 	if (0 != mtcp_bind(srv->mctx, srv_socket->fd, 
406 	  if(setsockopt(srv_socket->fd, SOL_SOCKET, SO_REUSEPORT, &port_reuse, sizeof(port_reuse)) == -1) {
411 	if (0 != bind(srv_socket->fd, (struct sockaddr *) &(srv_socket->addr), addr_len)) {
429 	if (-1 == mtcp_listen(srv->mctx, srv_socket->fd, srv->listen_backlog)) {
431 	if (-1 == listen(srv_socket->fd, 128 * 8)) {
453 		if (-1 == setsockopt(srv_socket->fd, IPPROTO_TCP, TCP_DEFER_ACCEPT, &v, sizeof(v))) {
464 		if (setsockopt(srv_socket->fd, SOL_SOCKET, SO_ACCEPTFILTER, &afa, sizeof(afa)) < 0) {
496 		srv->cur_fds = srv->first_entry->srv_sockets.ptr[srv->first_entry->srv_sockets.used - 1]->fd;
520 		srv->srv_sockets.ptr[srv->srv_sockets.used]->fd = 
521 			srv->first_entry->srv_sockets.ptr[srv->first_entry->srv_sockets.used - 1]->fd;
536 	if (srv_socket->fd != -1) {
539 			fdevent_event_del(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd);
540 			fdevent_unregister(srv->ev, srv_socket->fd);
543 		mtcp_close(srv->mctx, srv_socket->fd);
545 		close(srv_socket->fd);
562 		if (srv_socket->fd != -1) {
565 				fdevent_event_del(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd);
566 				fdevent_unregister(srv->ev, srv_socket->fd);
569 			mtcp_close(srv->mctx, srv_socket->fd);
571 			close(srv_socket->fd);
989 		fdevent_register(srv->ev, srv_socket->fd, network_server_handle_fdevent, srv_socket);
990 		fdevent_event_set(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd, FDEVENT_IN);
1040 		setsockopt(con->fd, IPPROTO_TCP, TCP_CORK, &corked, sizeof(corked));
1049 		ret = srv->network_backend_write(srv, con, con->fd, cq, max_bytes);
1060 		setsockopt(con->fd, IPPROTO_TCP, TCP_CORK, &corked, sizeof(corked));