Lines Matching defs:loop
63 static int uv__udp_set_socket(uv_loop_t* loop, uv_udp_t* handle, SOCKET socket,
85 loop->iocp,
128 int uv__udp_init_ex(uv_loop_t* loop,
132 uv__handle_init(loop, (uv_handle_t*) handle, UV_UDP);
158 err = uv__udp_set_socket(handle->loop, handle, sock, domain);
170 void uv__udp_close(uv_loop_t* loop, uv_udp_t* handle) {
178 uv__want_endgame(loop, (uv_handle_t*) handle);
183 void uv__udp_endgame(uv_loop_t* loop, uv_udp_t* handle) {
219 err = uv__udp_set_socket(handle->loop, handle, sock, addr->sa_family);
267 static void uv__udp_queue_recv(uv_loop_t* loop, uv_udp_t* handle) {
283 if (loop->active_udp_streams < uv_active_udp_streams_threshold) {
314 uv__insert_pending_req(loop, req);
322 uv__insert_pending_req(loop, req);
346 uv__insert_pending_req(loop, req);
354 uv__insert_pending_req(loop, req);
363 uv_loop_t* loop = handle->loop;
378 INCREASE_ACTIVE_COUNT(loop, handle);
379 loop->active_udp_streams++;
387 uv__udp_queue_recv(loop, handle);
396 handle->loop->active_udp_streams--;
397 DECREASE_ACTIVE_COUNT(loop, handle);
411 uv_loop_t* loop = handle->loop;
435 REGISTER_HANDLE_REQ(loop, handle, req);
436 uv__insert_pending_req(loop, (uv_req_t*)req);
443 REGISTER_HANDLE_REQ(loop, handle, req);
453 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle,
557 uv__udp_queue_recv(loop, handle);
564 void uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle,
575 UNREGISTER_HANDLE_REQ(loop, handle, req);
965 err = uv__udp_set_socket(handle->loop,