Lines Matching defs:loop

77 static void uv__fast_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) {
134 uv__insert_pending_req(loop, req);
139 static void uv__fast_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle,
196 uv__fast_poll_submit_poll_req(loop, handle);
200 uv__want_endgame(loop, (uv_handle_t*) handle);
238 static SOCKET uv__fast_poll_get_peer_socket(uv_loop_t* loop,
259 peer_socket = loop->poll_peer_sockets[index];
261 peer_socket = uv__fast_poll_create_peer_socket(loop->iocp, protocol_info);
262 loop->poll_peer_sockets[index] = peer_socket;
306 POST_COMPLETION_FOR_REQ(handle->loop, req);
332 POST_COMPLETION_FOR_REQ(handle->loop, req);
338 static void uv__slow_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) {
362 uv__insert_pending_req(loop, req);
368 static void uv__slow_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle,
401 uv__slow_poll_submit_poll_req(loop, handle);
405 uv__want_endgame(loop, (uv_handle_t*) handle);
410 int uv_poll_init(uv_loop_t* loop, uv_poll_t* handle, int fd) {
411 return uv_poll_init_socket(loop, handle, (SOCKET) uv__get_osfhandle(fd));
415 int uv_poll_init_socket(uv_loop_t* loop, uv_poll_t* handle,
447 uv__handle_init(loop, (uv_handle_t*) handle, UV_POLL);
464 peer_socket = uv__fast_poll_get_peer_socket(loop, &protocol_info);
508 uv__slow_poll_submit_poll_req(handle->loop, handle);
510 uv__fast_poll_submit_poll_req(handle->loop, handle);
528 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) {
530 uv__fast_poll_process_poll_req(loop, handle, req);
532 uv__slow_poll_process_poll_req(loop, handle, req);
537 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle) {
547 uv__want_endgame(loop, (uv_handle_t*) handle);
578 void uv__poll_endgame(uv_loop_t* loop, uv_poll_t* handle) {