Searched refs:incoming (Results 1 – 11 of 11) sorted by relevance
| /libuv/test/ |
| H A D | test-pipe-sendmsg.c | 38 static uv_pipe_t incoming[4]; variable
88 ASSERT_LT(incoming_count, ARRAY_SIZE(incoming)); in read_cb()
89 inc = &incoming[incoming_count++]; in read_cb()
94 if (incoming_count != ARRAY_SIZE(incoming)) in read_cb()
99 for (i = 0; i < ARRAY_SIZE(incoming); i++) in read_cb()
100 uv_close((uv_handle_t*) &incoming[i], close_cb); in read_cb()
111 int send_fds[ARRAY_SIZE(incoming)]; in TEST_IMPL()
157 ASSERT_EQ(ARRAY_SIZE(incoming), incoming_count); in TEST_IMPL()
158 ASSERT_EQ(ARRAY_SIZE(incoming) + 1, close_called); in TEST_IMPL()
|
| H A D | test-tcp-alloc-cb-fail.c | 31 static uv_tcp_t incoming; variable
59 uv_close((uv_handle_t*) &incoming, close_cb); in conn_read_cb()
80 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
81 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
82 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, in connection_cb()
|
| H A D | test-tcp-write-in-a-row.c | 31 static uv_tcp_t incoming; variable
55 uv_close((uv_handle_t*) &incoming, close_cb); in write_cb()
99 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
100 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
101 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-close-accept.c | 119 uv_tcp_t* incoming; in connection_cb() local
128 incoming = &tcp_incoming[got_connections++]; in connection_cb()
129 ASSERT_OK(uv_tcp_init(server->loop, incoming)); in connection_cb()
130 ASSERT_OK(uv_accept(server, (uv_stream_t*) incoming)); in connection_cb()
137 incoming = &tcp_incoming[i]; in connection_cb()
138 ASSERT_OK(uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-try-write-error.c | 31 static uv_tcp_t incoming; variable
65 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
66 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
69 uv_close((uv_handle_t*) &incoming, incoming_close_cb); in connection_cb()
|
| H A D | test-tcp-try-write.c | 33 static uv_tcp_t incoming; variable
92 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
93 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
96 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-write-queue-order.c | 34 static uv_tcp_t incoming; variable
52 uv_close((uv_handle_t*) &incoming, close_cb); in timer_cb()
89 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
90 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
|
| /libuv/docs/src/ |
| H A D | stream.rst | 73 Callback called when a stream server has received an incoming connection.
116 Start listening for incoming connections. `backlog` indicates the number of
118 incoming connection is received the :c:type:`uv_connection_cb` callback is
123 This call is used in conjunction with :c:func:`uv_listen` to accept incoming
138 Read data from an incoming stream. The :c:type:`uv_read_cb` callback will
|
| H A D | tcp.rst | 123 `SO_REUSEPORT` with the capability of load balancing that distribute incoming
|
| H A D | udp.rst | 71 * the port, which means incoming datagrams are distributed across
468 Stop listening for incoming datagrams.
|
| /libuv/docs/src/guide/ |
| H A D | filesystem.rst | 224 buffers are required to hold incoming data. ``read_stdin`` will be called with
|
Completed in 57 milliseconds
