| /libuv/src/unix/ |
| H A D | async.c | 83 handle->pending = 0; in uv_async_init()
94 _Atomic int* pending; in uv_async_send() local
97 pending = (_Atomic int*) &handle->pending; in uv_async_send()
108 if (atomic_exchange(pending, 1) == 0) in uv_async_send()
121 _Atomic int* pending; in uv__async_spin() local
125 pending = (_Atomic int*) &handle->pending; in uv__async_spin()
130 atomic_store(pending, 1); in uv__async_spin()
166 _Atomic int *pending; local
201 pending = (_Atomic int*) &h->pending;
202 if (atomic_exchange(pending, 0) == 0)
[all …]
|
| H A D | process.c | 108 struct uv__queue pending; in uv__wait_children() local
112 uv__queue_init(&pending); in uv__wait_children()
150 uv__queue_insert_tail(&pending, &process->queue); in uv__wait_children()
153 h = &pending; in uv__wait_children()
176 assert(uv__queue_empty(&pending)); in uv__wait_children()
|
| /libuv/test/ |
| H A D | test-ipc-send-recv.c | 91 uv_handle_type pending; in recv_cb() local
120 pending = uv_pipe_pending_type(pipe); in recv_cb()
121 ASSERT_EQ(pending, ctx.expected_type); in recv_cb()
123 if (pending == UV_NAMED_PIPE) in recv_cb()
125 else if (pending == UV_TCP) in recv_cb()
306 uv_handle_type pending; in read_cb() local
331 pending = uv_pipe_pending_type(pipe); in read_cb()
332 ASSERT(pending == UV_NAMED_PIPE || pending == UV_TCP); in read_cb()
334 if (pending == UV_NAMED_PIPE) in read_cb()
336 else if (pending == UV_TCP) in read_cb()
|
| H A D | test-ipc.c | 148 uv_handle_type pending; in on_read() local
171 pending = uv_pipe_pending_type(pipe); in on_read()
180 ASSERT_EQ(pending, UV_TCP); in on_read()
218 uv_handle_type pending; in on_read_listen_after_bound_twice() local
241 pending = uv_pipe_pending_type(pipe); in on_read_listen_after_bound_twice()
244 ASSERT_NE(pending, UV_UNKNOWN_HANDLE); in on_read_listen_after_bound_twice()
249 ASSERT_EQ(pending, UV_TCP); in on_read_listen_after_bound_twice()
260 ASSERT_EQ(pending, UV_TCP); in on_read_listen_after_bound_twice()
356 uv_handle_type pending; in on_read_connection() local
378 pending = uv_pipe_pending_type(pipe); in on_read_connection()
[all …]
|
| H A D | test-pipe-sendmsg.c | 78 uv_handle_type pending; in read_cb() local
85 pending = uv_pipe_pending_type(p); in read_cb()
86 ASSERT_EQ(pending, UV_NAMED_PIPE); in read_cb()
|
| /libuv/docs/code/multi-echo-server/ |
| H A D | worker.c | 65 uv_handle_type pending = uv_pipe_pending_type(pipe); in on_new_connection() local
66 assert(pending == UV_TCP); in on_new_connection()
|
| /libuv/docs/code/uvwget/ |
| H A D | main.c | 61 int pending; in check_multi_info() local
63 while ((message = curl_multi_info_read(curl_handle, &pending))) { in check_multi_info()
|
| /libuv/docs/src/guide/ |
| H A D | eventloops.rst | 31 runs pending timer, idle and prepare callbacks, and invokes any pending I/O
|
| H A D | threads.rst | 246 ``uv_cancel()`` is useful to cleanup pending tasks if the user requests
249 quickly and not wait until all pending requests are run.
320 least once* after the call to ``uv_async_send``. If you have no pending
|
| H A D | processes.rst | 157 pending events, while UV_RUN_NOWAIT will return immediately. We use NOWAIT
158 so that one of the loops isn't starved because the other one has no pending
|
| /libuv/docs/src/ |
| H A D | migration_010_100.rst | 199 uv_handle_type pending) {
203 In libuv 1.0, `uv_read2_start` was removed, and the user needs to check if there are pending
214 pending = uv_pipe_pending_type((uv_pipe_t*) handle);
|
| H A D | poll.rst | 146 Calling :c:func:`uv_poll_stop` is effective immediately: any pending
148 was already pending.
|
| H A D | request.rst | 70 Cancel a pending request. Fails if the request is executing or has finished
|
| H A D | stream.rst | 109 Shutdown the outgoing (write) side of a duplex stream. It waits for pending
156 may be pending on the next input event on that TTY on Windows, and does not
|
| H A D | loop.rst | 127 there are no pending callbacks. Returns zero when done (no active handles
131 pending callbacks. Returns zero if done (no active handles
|
| H A D | pipe.rst | 140 Set the number of pending pipe instance handles when the pipe server is
|
| H A D | design.rst | 89 * If there are any handles pending to be closed, the timeout is 0.
|
| H A D | handle.rst | 67 not related in any way to the pending data to be read. The user is free to allocate the amount
|
| /libuv/include/uv/ |
| H A D | unix.h | 327 int pending; \
|
| /libuv/ |
| H A D | Makefile.am | 228 test/test-pipe-pending-instances.c \
256 test/test-signal-pending-on-close.c \
|
| H A D | CMakeLists.txt | 602 test/test-pipe-pending-instances.c
629 test/test-signal-pending-on-close.c
|
| H A D | ChangeLog | 991 * loop: add pending work to loop-alive check (Jameson Nash)
1314 * doc,poll: add notes (repeated cb & cancel pending cb) (Elad Nachmias)
1428 * win,tcp: avoid reinserting a pending request (
2004 * unix,signal: keep handle active if pending signal (Santiago Gimeno)
3504 * win, tty: fix crash on restarting with pending data (Nicholas Vavilov)
4148 * win: fix setting pipe pending instances after bind (Saúl Ibarra Corretgé)
5188 * pipe: allow queueing pending handles (Fedor Indutny)
|
