Lines Matching defs:loop
58 static int uv__udp_set_socket(uv_loop_t* loop, uv_udp_t* handle, SOCKET socket,
80 loop->iocp,
123 int uv__udp_init_ex(uv_loop_t* loop,
127 uv__handle_init(loop, (uv_handle_t*) handle, UV_UDP);
153 err = uv__udp_set_socket(handle->loop, handle, sock, domain);
165 void uv__udp_close(uv_loop_t* loop, uv_udp_t* handle) {
173 uv__want_endgame(loop, (uv_handle_t*) handle);
178 void uv__udp_endgame(uv_loop_t* loop, uv_udp_t* handle) {
214 err = uv__udp_set_socket(handle->loop, handle, sock, addr->sa_family);
262 static void uv__udp_queue_recv(uv_loop_t* loop, uv_udp_t* handle) {
293 uv__insert_pending_req(loop, req);
301 uv__insert_pending_req(loop, req);
309 uv_loop_t* loop = handle->loop;
324 INCREASE_ACTIVE_COUNT(loop, handle);
332 uv__udp_queue_recv(loop, handle);
341 DECREASE_ACTIVE_COUNT(loop, handle);
355 uv_loop_t* loop = handle->loop;
379 REGISTER_HANDLE_REQ(loop, handle, req);
380 uv__insert_pending_req(loop, (uv_req_t*)req);
387 REGISTER_HANDLE_REQ(loop, handle, req);
397 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle,
446 /* Prevent loop starvation when the data comes in as fast as
512 uv__udp_queue_recv(loop, handle);
519 void uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle,
530 UNREGISTER_HANDLE_REQ(loop, handle, req);
920 err = uv__udp_set_socket(handle->loop,