Lines Matching defs:loop
75 static void uv__fast_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) {
132 uv__insert_pending_req(loop, req);
137 static void uv__fast_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle,
194 uv__fast_poll_submit_poll_req(loop, handle);
198 uv__want_endgame(loop, (uv_handle_t*) handle);
236 static SOCKET uv__fast_poll_get_peer_socket(uv_loop_t* loop,
257 peer_socket = loop->poll_peer_sockets[index];
259 peer_socket = uv__fast_poll_create_peer_socket(loop->iocp, protocol_info);
260 loop->poll_peer_sockets[index] = peer_socket;
304 POST_COMPLETION_FOR_REQ(handle->loop, req);
330 POST_COMPLETION_FOR_REQ(handle->loop, req);
336 static void uv__slow_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) {
360 uv__insert_pending_req(loop, req);
366 static void uv__slow_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle,
399 uv__slow_poll_submit_poll_req(loop, handle);
403 uv__want_endgame(loop, (uv_handle_t*) handle);
408 int uv_poll_init(uv_loop_t* loop, uv_poll_t* handle, int fd) {
409 return uv_poll_init_socket(loop, handle, (SOCKET) uv__get_osfhandle(fd));
413 int uv_poll_init_socket(uv_loop_t* loop, uv_poll_t* handle,
446 uv__handle_init(loop, (uv_handle_t*) handle, UV_POLL);
463 peer_socket = uv__fast_poll_get_peer_socket(loop, &protocol_info);
507 uv__slow_poll_submit_poll_req(handle->loop, handle);
509 uv__fast_poll_submit_poll_req(handle->loop, handle);
527 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) {
529 uv__fast_poll_process_poll_req(loop, handle, req);
531 uv__slow_poll_process_poll_req(loop, handle, req);
536 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle) {
546 uv__want_endgame(loop, (uv_handle_t*) handle);
577 void uv__poll_endgame(uv_loop_t* loop, uv_poll_t* handle) {