Lines Matching refs:fd

397 	evutil_socket_t fd;  in be_async_destruct()  local
405 fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_destruct()
406 if (fd != (evutil_socket_t)EVUTIL_INVALID_SOCKET && in be_async_destruct()
408 evutil_closesocket(fd); in be_async_destruct()
419 evutil_socket_t fd; in bev_async_set_wsa_error() local
421 fd = evbuffer_overlapped_get_fd_(bev->input); in bev_async_set_wsa_error()
422 WSAGetOverlappedResult(fd, &eo->overlapped, &bytes, FALSE, &flags); in bev_async_set_wsa_error()
544 evutil_socket_t fd, int options) in bufferevent_async_new_() argument
555 if (fd >= 0 && event_iocp_port_associate_(iocp, fd, 1)<0) { in bufferevent_async_new_()
564 if (!(bev->input = evbuffer_overlapped_new_(fd))) { in bufferevent_async_new_()
568 if (!(bev->output = evbuffer_overlapped_new_(fd))) { in bufferevent_async_new_()
587 bev_a->ok = fd >= 0; in bufferevent_async_new_()
619 bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd, in bufferevent_async_connect_() argument
628 EVUTIL_ASSERT(ext && ext->ConnectEx && fd >= 0 && sa != NULL); in bufferevent_async_connect_()
647 if (bind(fd, (struct sockaddr *)&ss, sizeof(ss)) < 0 && in bufferevent_async_connect_()
653 rc = ext->ConnectEx(fd, sa, socklen, NULL, 0, NULL, in bufferevent_async_connect_()
670 data->fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl()
676 if (data->fd == evbuffer_overlapped_get_fd_(bev->input)) in be_async_ctrl()
680 if (event_iocp_port_associate_(iocp, data->fd, 1) < 0) { in be_async_ctrl()
684 evbuffer_overlapped_set_fd_(bev->input, data->fd); in be_async_ctrl()
685 evbuffer_overlapped_set_fd_(bev->output, data->fd); in be_async_ctrl()
686 bev_a->ok = data->fd >= 0; in be_async_ctrl()
691 evutil_socket_t fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl() local
692 if (fd != (evutil_socket_t)EVUTIL_INVALID_SOCKET && in be_async_ctrl()
694 closesocket(fd); in be_async_ctrl()