Lines Matching refs:loop
56 #define REGISTER_HANDLE_REQ(loop, handle) \ argument
58 INCREASE_ACTIVE_COUNT((loop), (handle)); \
59 uv__req_register((loop)); \
62 #define UNREGISTER_HANDLE_REQ(loop, handle) \ argument
64 DECREASE_ACTIVE_COUNT((loop), (handle)); \
65 uv__req_unregister((loop)); \
76 #define POST_COMPLETION_FOR_REQ(loop, req) \ argument
77 if (!PostQueuedCompletionStatus((loop)->iocp, \
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req() argument
92 if (loop->pending_reqs_tail) { in uv__insert_pending_req()
97 uv_req_t* current = loop->pending_reqs_tail; in uv__insert_pending_req()
101 } while(current != loop->pending_reqs_tail); in uv__insert_pending_req()
104 req->next_req = loop->pending_reqs_tail->next_req; in uv__insert_pending_req()
105 loop->pending_reqs_tail->next_req = req; in uv__insert_pending_req()
106 loop->pending_reqs_tail = req; in uv__insert_pending_req()
109 loop->pending_reqs_tail = req; in uv__insert_pending_req()
114 #define DELEGATE_STREAM_REQ(loop, req, method, handle_at) \ argument
118 uv__process_tcp_##method##_req(loop, \
124 uv__process_pipe_##method##_req(loop, \
130 uv__process_tty_##method##_req(loop, \
141 INLINE static void uv__process_reqs(uv_loop_t* loop) { in uv__process_reqs() argument
146 if (loop->pending_reqs_tail == NULL) in uv__process_reqs()
149 first = loop->pending_reqs_tail->next_req; in uv__process_reqs()
151 loop->pending_reqs_tail = NULL; in uv__process_reqs()
159 DELEGATE_STREAM_REQ(loop, req, read, data); in uv__process_reqs()
163 DELEGATE_STREAM_REQ(loop, (uv_write_t*) req, write, handle); in uv__process_reqs()
167 DELEGATE_STREAM_REQ(loop, req, accept, data); in uv__process_reqs()
171 DELEGATE_STREAM_REQ(loop, (uv_connect_t*) req, connect, handle); in uv__process_reqs()
175 DELEGATE_STREAM_REQ(loop, (uv_shutdown_t*) req, shutdown, handle); in uv__process_reqs()
179 uv__process_udp_recv_req(loop, (uv_udp_t*) req->data, req); in uv__process_reqs()
183 uv__process_udp_send_req(loop, in uv__process_reqs()
189 uv__process_async_wakeup_req(loop, (uv_async_t*) req->data, req); in uv__process_reqs()
193 uv__process_signal_req(loop, (uv_signal_t*) req->data, req); in uv__process_reqs()
197 uv__process_poll_req(loop, (uv_poll_t*) req->data, req); in uv__process_reqs()
201 uv__process_proc_exit(loop, (uv_process_t*) req->data); in uv__process_reqs()
205 uv__process_fs_event_req(loop, req, (uv_fs_event_t*) req->data); in uv__process_reqs()
