Lines Matching refs:fd

104 	int fd; /* fd to the proxy process */  member
131 hctx->fd = -1; in handler_ctx_init()
344 if (hctx->fd != -1) { in proxy_connection_close()
345 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_connection_close()
346 fdevent_unregister(srv->ev, hctx->fd); in proxy_connection_close()
348 close(hctx->fd); in proxy_connection_close()
370 int proxy_fd = hctx->fd; in proxy_establish_connection()
653 int proxy_fd = hctx->fd; in proxy_demux_response()
656 if (ioctl(hctx->fd, FIONREAD, &b)) { in proxy_demux_response()
678 if (-1 == (r = read(hctx->fd, hctx->response->ptr + hctx->response->used - 1, b))) { in proxy_demux_response()
775 if (-1 == (hctx->fd = socket(AF_INET6, SOCK_STREAM, 0))) { in proxy_write_request()
782 if (-1 == (hctx->fd = socket(AF_INET, SOCK_STREAM, 0))) { in proxy_write_request()
791 fdevent_register(srv->ev, hctx->fd, proxy_handle_fdevent, hctx); in proxy_write_request()
793 if (-1 == fdevent_fcntl_set(srv->ev, hctx->fd)) { in proxy_write_request()
805 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in proxy_write_request()
828 ret = srv->network_backend_write(srv, con, hctx->fd, hctx->wb, MAX_WRITE_LIMIT); in proxy_write_request()
845 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_write_request()
846 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_IN); in proxy_write_request()
848 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in proxy_write_request()
922 hctx->fd); in SUBREQUEST_FUNC()
1007 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_handle_fdevent()
1011 if (0 != getsockopt(hctx->fd, SOL_SOCKET, SO_ERROR, &socket_error, &socket_error_len)) { in proxy_handle_fdevent()
1068 hctx->fd); in proxy_handle_fdevent()