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