Lines Matching refs:req
31 #define SET_REQ_STATUS(req, status) \
32 (req)->u.io.overlapped.Internal = (ULONG_PTR) (status)
34 #define SET_REQ_ERROR(req, error) \
35 SET_REQ_STATUS((req), NTSTATUS_FROM_WIN32((error)))
40 #define SET_REQ_SUCCESS(req) \
41 SET_REQ_STATUS((req), STATUS_SUCCESS)
43 #define GET_REQ_STATUS(req) \
44 ((NTSTATUS) (req)->u.io.overlapped.Internal)
46 #define REQ_SUCCESS(req) \
47 (NT_SUCCESS(GET_REQ_STATUS((req))))
49 #define GET_REQ_ERROR(req) \
50 (pRtlNtStatusToDosError(GET_REQ_STATUS((req))))
52 #define GET_REQ_SOCK_ERROR(req) \
53 (uv__ntstatus_to_winsock_error(GET_REQ_STATUS((req))))
56 #define REGISTER_HANDLE_REQ(loop, handle, req) \
59 uv__req_register((loop), (req)); \
62 #define UNREGISTER_HANDLE_REQ(loop, handle, req) \
65 uv__req_unregister((loop), (req)); \
76 #define POST_COMPLETION_FOR_REQ(loop, req) \
80 &((req)->u.io.overlapped))) { \
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) {
91 req->next_req = NULL;
99 assert(req != current);
104 req->next_req = loop->pending_reqs_tail->next_req;
105 loop->pending_reqs_tail->next_req = req;
106 loop->pending_reqs_tail = req;
108 req->next_req = req;
109 loop->pending_reqs_tail = req;
114 #define DELEGATE_STREAM_REQ(loop, req, method, handle_at) \
116 switch (((uv_handle_t*) (req)->handle_at)->type) { \
119 (uv_tcp_t*) ((req)->handle_at), \
120 req); \
125 (uv_pipe_t*) ((req)->handle_at), \
126 req); \
131 (uv_tty_t*) ((req)->handle_at), \
132 req); \
142 uv_req_t* req;
154 req = next;
155 next = req->next_req != first ? req->next_req : NULL;
157 switch (req->type) {
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);
184 ((uv_udp_send_t*) req)->handle,
185 (uv_udp_send_t*) req);
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);