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 16 milliseconds