Lines Matching refs:req
31 #define SET_REQ_STATUS(req, status) \ argument
32 (req)->u.io.overlapped.Internal = (ULONG_PTR) (status)
34 #define SET_REQ_ERROR(req, error) \ argument
35 SET_REQ_STATUS((req), NTSTATUS_FROM_WIN32((error)))
40 #define SET_REQ_SUCCESS(req) \ argument
41 SET_REQ_STATUS((req), STATUS_SUCCESS)
43 #define GET_REQ_STATUS(req) \ argument
44 ((NTSTATUS) (req)->u.io.overlapped.Internal)
46 #define REQ_SUCCESS(req) \ argument
47 (NT_SUCCESS(GET_REQ_STATUS((req))))
49 #define GET_REQ_ERROR(req) \ argument
50 (pRtlNtStatusToDosError(GET_REQ_STATUS((req))))
52 #define GET_REQ_SOCK_ERROR(req) \ argument
53 (uv__ntstatus_to_winsock_error(GET_REQ_STATUS((req))))
76 #define POST_COMPLETION_FOR_REQ(loop, req) \ argument
80 &((req)->u.io.overlapped))) { \
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req() argument
91 req->next_req = NULL; in uv__insert_pending_req()
99 assert(req != current); 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()
108 req->next_req = 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
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; in uv__process_reqs() local
154 req = next; in uv__process_reqs()
155 next = req->next_req != first ? req->next_req : NULL; in uv__process_reqs()
157 switch (req->type) { 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()
184 ((uv_udp_send_t*) req)->handle, in uv__process_reqs()
185 (uv_udp_send_t*) req); 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()
