Home
last modified time | relevance | path

Searched refs:uv_req_t (Results 1 - 25 of 46) sorted by relevance

12

/third_party/node/deps/uv/src/win/
H A Dinternal.h84 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
88 uv_req_t* req);
110 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req);
139 uv_req_t* req);
143 uv_req_t* raw_req);
168 uv_req_t* req);
176 uv_req_t* raw_req);
193 uv_req_t* req);
218 uv_req_t* req);
231 uv_req_t* re
[all...]
H A Dreq-inl.h85 INLINE static uv_req_t* uv__overlapped_to_req(OVERLAPPED* overlapped) { in uv__overlapped_to_req()
86 return CONTAINING_RECORD(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req()
97 uv_req_t* current = loop->pending_reqs_tail; in uv__insert_pending_req()
142 uv_req_t* req; in uv__process_reqs()
143 uv_req_t* first; in uv__process_reqs()
144 uv_req_t* next; in uv__process_reqs()
H A Dpoll.c76 uv_req_t* req; in uv__fast_poll_submit_poll_req()
138 uv_req_t* req) { in uv__fast_poll_process_poll_req()
268 uv_req_t* req = (uv_req_t*) arg; in uv__slow_poll_thread_proc()
337 uv_req_t* req; in uv__slow_poll_submit_poll_req()
367 uv_req_t* req) { in uv__slow_poll_process_poll_req()
527 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) { in uv__process_poll_req()
H A Dasync.c41 uv_req_t* req; in uv_async_init()
87 uv_req_t* req) { in uv__process_async_wakeup_req()
H A Dtcp.c354 uv_req_t* req; in post_completion()
357 req = (uv_req_t*) context; in post_completion()
412 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
420 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
446 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
457 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
462 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
530 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
539 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
544 uv__insert_pending_req(loop, (uv_req_t*)re in uv__tcp_queue_read()
[all...]
H A Dpipe.c593 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
607 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
614 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
625 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
883 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_pipe_connect()
899 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_pipe_connect()
1019 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_queue_accept()
1039 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_queue_accept()
1343 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__pipe_queue_read()
1382 handle->pipe.conn.non_overlapped_writes_tail->next_req = (uv_req_t*)re in uv__insert_non_overlapped_write_req()
[all...]
H A Dtty.c438 uv_req_t* req; in uv_tty_post_raw_read()
443 req = (uv_req_t*) data; in uv_tty_post_raw_read()
478 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tty_queue_read_raw()
489 uv_req_t* req; in uv_tty_line_read_thread()
499 req = (uv_req_t*) data; in uv_tty_line_read_thread()
614 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tty_queue_read_line()
698 uv_req_t* req) { in uv_process_tty_read_raw_req()
961 uv_req_t* req) { in uv_process_tty_read_line_req()
1003 uv_req_t* req) { in uv__process_tty_read_req()
1041 uv__insert_pending_req(handle->loop, (uv_req_t*) in uv__tty_read_start()
[all...]
/third_party/libuv/src/win/
H A Dreq-inl.h85 INLINE static uv_req_t* uv__overlapped_to_req(OVERLAPPED* overlapped) { in uv__overlapped_to_req()
86 return CONTAINING_RECORD(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req()
97 uv_req_t* current = loop->pending_reqs_tail; in uv__insert_pending_req()
142 uv_req_t* req; in uv__process_reqs()
143 uv_req_t* first; in uv__process_reqs()
144 uv_req_t* next; in uv__process_reqs()
H A Dinternal.h86 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
90 uv_req_t* req);
112 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req);
141 uv_req_t* req);
145 uv_req_t* raw_req);
170 uv_req_t* req);
185 uv_req_t* req);
210 uv_req_t* req);
223 uv_req_t* req);
243 void uv__process_fs_event_req(uv_loop_t* loop, uv_req_t* re
[all...]
H A Dpoll.c78 uv_req_t* req; in uv__fast_poll_submit_poll_req()
140 uv_req_t* req) { in uv__fast_poll_process_poll_req()
270 uv_req_t* req = (uv_req_t*) arg; in uv__slow_poll_thread_proc()
339 uv_req_t* req; in uv__slow_poll_submit_poll_req()
369 uv_req_t* req) { in uv__slow_poll_process_poll_req()
528 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) { in uv__process_poll_req()
H A Dasync.c41 uv_req_t* req; in uv_async_init()
87 uv_req_t* req) { in uv__process_async_wakeup_req()
H A Dtcp.c344 uv_req_t* req; in post_completion()
347 req = (uv_req_t*) context; in post_completion()
402 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
410 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
436 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
447 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
452 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
503 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
512 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
517 uv__insert_pending_req(loop, (uv_req_t*)re in uv__tcp_queue_read()
[all...]
H A Dtty.c433 uv_req_t* req; in uv_tty_post_raw_read()
438 req = (uv_req_t*) data; in uv_tty_post_raw_read()
473 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tty_queue_read_raw()
484 uv_req_t* req; in uv_tty_line_read_thread()
496 req = (uv_req_t*) data; in uv_tty_line_read_thread()
608 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tty_queue_read_line()
692 uv_req_t* req) { in uv_process_tty_read_raw_req()
950 uv_req_t* req) { in uv_process_tty_read_line_req()
992 uv_req_t* req) { in uv__process_tty_read_req()
1030 uv__insert_pending_req(handle->loop, (uv_req_t*) in uv__tty_read_start()
[all...]
H A Dpipe.c601 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
615 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
622 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
633 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
869 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_pipe_connect()
975 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_pipe_connect2()
993 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_pipe_connect2()
1113 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_queue_accept()
1133 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_queue_accept()
1438 uv__insert_pending_req(loop, (uv_req_t*)re in uv__pipe_queue_read()
[all...]
/third_party/libuv/test/
H A Dbenchmark-pump.c41 static uv_req_t* req_alloc(void);
42 static void req_free(uv_req_t* uv_req);
193 req_free((uv_req_t*) req); in write_cb()
226 req_free((uv_req_t*) req); in connect_cb()
318 static uv_req_t* req_alloc(void) { in req_alloc()
324 return (uv_req_t*) req; in req_alloc()
328 return (uv_req_t*) req; in req_alloc()
332 static void req_free(uv_req_t* uv_req) { in req_free()
H A Dtest-threadpool-cancel.c94 static int known_broken(uv_req_t* req) { in known_broken()
126 ASSERT_NE(known_broken((uv_req_t*) req) || \ in fs_cb()
165 uv_req_t* req; in timer_cb()
171 req = (uv_req_t*) ((char*) ci->reqs + i * ci->stride); in timer_cb()
281 ASSERT_OK(uv_cancel((uv_req_t*) &req)); in TEST_IMPL()
377 ASSERT_OK(uv_cancel((uv_req_t*) &req)); in TEST_IMPL()
410 ASSERT_EQ(uv_cancel((uv_req_t*) &req), UV_EBUSY); in TEST_IMPL()
/third_party/libuv/src/
H A Duv-data-getter-setters.c65 uv_req_type uv_req_get_type(const uv_req_t* req) { in uv_req_get_type()
69 void* uv_req_get_data(const uv_req_t* req) { in uv_req_get_data()
73 void uv_req_set_data(uv_req_t* req, void* data) { in uv_req_set_data()
H A Dthreadpool.c596 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) { in uv__work_cancel()
811 uv_req_t* req, in uv__work_submit()
849 uv_req_t* req, in uv__work_submit_with_qos()
898 (uv_req_t*)req, in uv_queue_work()
945 (uv_req_t*)req, in uv_queue_work_with_qos()
960 int uv_cancel(uv_req_t* req) { in uv_cancel()
/third_party/node/deps/uv/src/
H A Duv-data-getter-setters.c65 uv_req_type uv_req_get_type(const uv_req_t* req) { in uv_req_get_type()
69 void* uv_req_get_data(const uv_req_t* req) { in uv_req_get_data()
73 void uv_req_set_data(uv_req_t* req, void* data) { in uv_req_set_data()
/third_party/node/src/
H A Dnode_postmortem_metadata.cc59 OffsetOf<ListNode<ReqWrapBase>, ReqWrap<uv_req_t>>( in GenDebugSymbols()
60 &ReqWrap<uv_req_t>::req_wrap_queue_); in GenDebugSymbols()
H A Dthreadpoolwork-inl.h63 return uv_cancel(reinterpret_cast<uv_req_t*>(&work_req_)); in CancelWork()
/third_party/libuv/src/unix/
H A Dgetnameinfo.c101 uv__req_init(loop, (uv_req_t*)req, UV_GETNAMEINFO); in uv_getnameinfo()
112 (uv_req_t*)req, in uv_getnameinfo()
/third_party/libuv/include/uv/
H A Dwin.h336 uv_req_t* pending_reqs_tail; \
468 uv_req_t recv_req; \
545 uv_req_t poll_req_1; \
546 uv_req_t poll_req_2; \
/third_party/node/deps/uv/include/uv/
H A Dwin.h333 uv_req_t* pending_reqs_tail; \
464 uv_req_t recv_req; \
541 uv_req_t poll_req_1; \
542 uv_req_t poll_req_2; \
/third_party/node/test/cctest/
H A Dtest_node_postmortem_metadata.cc54 class TestReqWrap : public node::ReqWrap<uv_req_t> {
61 : node::ReqWrap<uv_req_t>(env, in TestReqWrap()

Completed in 21 milliseconds

12