Home
last modified time | relevance | path

Searched refs:uv_req_t (Results 1 – 25 of 26) sorted by relevance

12

/libuv/docs/src/
H A Drequest.rst4 :c:type:`uv_req_t` --- Base request
7 `uv_req_t` is the base type for all libuv request types.
9 Structures are aligned so that any libuv request can be cast to `uv_req_t`.
16 .. c:type:: uv_req_t
48 .. c:member:: void* uv_req_t.data
52 .. c:member:: uv_req_type uv_req_t.type
68 .. c:function:: int uv_cancel(uv_req_t* req)
96 .. c:function:: void* uv_req_get_data(const uv_req_t* req)
102 .. c:function:: void uv_req_set_data(uv_req_t* req, void* data)
108 .. c:function:: uv_req_type uv_req_get_type(const uv_req_t* req)
H A Dthreadpool.rst58 .. seealso:: The :c:type:`uv_req_t` members also apply.
72 .. seealso:: The :c:type:`uv_req_t` API functions also apply.
H A Ddns.rst66 .. seealso:: The :c:type:`uv_req_t` members also apply.
108 .. seealso:: The :c:type:`uv_req_t` API functions also apply.
H A Dfs.rst216 .. seealso:: The :c:type:`uv_req_t` members also apply.
539 .. seealso:: The :c:type:`uv_req_t` API functions also apply.
/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 container_of(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.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);
183 uv_req_t* req);
208 uv_req_t* req);
221 uv_req_t* req);
241 void uv__process_fs_event_req(uv_loop_t* loop, uv_req_t* 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 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 Dtcp.c356 uv_req_t* req; in post_completion()
359 req = (uv_req_t*) context; in post_completion()
414 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
422 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
448 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
464 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_accept()
515 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
529 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_queue_read()
838 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__tcp_try_connect()
983 uv_req_t* req) { in uv__process_tcp_read_req()
[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*) &handle->read_req); in uv__tty_read_start()
[all …]
H A Dpipe.c606 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
620 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
627 uv__insert_pending_req(loop, (uv_req_t*) req); in uv__pipe_shutdown()
638 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()
1437 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__pipe_queue_read()
1479 req->next_req = (uv_req_t*)req; in uv__insert_non_overlapped_write_req()
2118 uv_req_t* req) { in uv__process_pipe_read_req()
[all …]
H A Dsignal.c235 uv_req_t* req) { in uv__process_signal_req()
H A Dcore.c431 uv_req_t* req; in uv__poll_wine()
520 uv_req_t* req; in uv__poll()
H A Dfs-event.c60 uv__insert_pending_req(loop, (uv_req_t*)&handle->req); in uv__fs_event_queue_readdirchanges()
416 void uv__process_fs_event_req(uv_loop_t* loop, uv_req_t* req, in uv__process_fs_event_req()
H A Dstream.c225 uv__insert_pending_req(loop, (uv_req_t*) req); in uv_shutdown()
H A Dudp.c269 uv_req_t* req; in uv__udp_queue_recv()
386 uv__insert_pending_req(loop, (uv_req_t*)req); in uv__send()
404 uv_req_t* req) { in uv__process_udp_recv_req()
/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()
/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.c281 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) { in uv__work_cancel()
388 int uv_cancel(uv_req_t* req) { in uv_cancel()
/libuv/include/uv/
H A Dwin.h335 uv_req_t* pending_reqs_tail; \
467 uv_req_t recv_req; \
544 uv_req_t poll_req_1; \
545 uv_req_t poll_req_2; \
/libuv/docs/code/queue-cancel/
H A Dmain.c38 uv_cancel((uv_req_t*) &fib_reqs[i]); in signal_handler()
/libuv/src/unix/
H A Dgetnameinfo.c101 uv__req_init(loop, (uv_req_t*)req, UV_GETNAMEINFO); in uv_getnameinfo()
/libuv/include/
H A Duv.h239 typedef struct uv_req_s uv_req_t; typedef
492 UV_EXTERN void* uv_req_get_data(const uv_req_t* req);
493 UV_EXTERN void uv_req_set_data(uv_req_t* req, void* data);
494 UV_EXTERN uv_req_type uv_req_get_type(const uv_req_t* req);
1182 UV_EXTERN int uv_cancel(uv_req_t* req);
/libuv/docs/src/guide/
H A Dbasics.rst168 typedef struct uv_req_s uv_req_t;

Completed in 61 milliseconds

12