/third_party/libuv/test/ |
D | test-multiple-listen.c | 40 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 59 r = uv_listen((uv_stream_t*)&server, 128, connection_cb); in start_server() 62 r = uv_listen((uv_stream_t*)&server, 128, connection_cb); in start_server()
|
D | test-emfile.c | 31 static void connection_cb(uv_stream_t* server_handle, int status); 66 ASSERT(0 == uv_listen((uv_stream_t*) &server_handle, 8, connection_cb)); in TEST_IMPL() 102 static void connection_cb(uv_stream_t* server_handle, int status) { in connection_cb() function
|
D | blackhole-server.c | 35 static void connection_cb(uv_stream_t* stream, int status); 42 static void connection_cb(uv_stream_t* stream, int status) { in connection_cb() function 114 r = uv_listen((uv_stream_t*)&tcp_server, 128, connection_cb); in HELPER_IMPL()
|
D | test-tcp-write-to-half-open-connection.c | 29 static void connection_cb(uv_stream_t* server, int status); 44 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 121 r = uv_listen((uv_stream_t*)&tcp_server, 1, connection_cb); in TEST_IMPL()
|
D | test-pipe-pending-instances.c | 27 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 49 r = uv_listen((uv_stream_t*)&pipe_handle, 128, connection_cb); in TEST_IMPL()
|
D | test-pipe-connect-multiple.c | 44 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 88 r = uv_listen((uv_stream_t*)&server_handle, 128, connection_cb); in TEST_IMPL()
|
D | test-tcp-try-write-error.c | 62 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 81 ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, connection_cb)); in start_server()
|
D | test-tcp-alloc-cb-fail.c | 77 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 97 ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, connection_cb)); in start_server()
|
D | test-tcp-try-write.c | 89 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 107 ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, connection_cb)); in start_server()
|
D | test-tcp-close.c | 74 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 91 r = uv_listen((uv_stream_t*)handle, 128, connection_cb); in start_server()
|
D | test-tcp-unexpected-read.c | 74 static void connection_cb(uv_stream_t* handle, int status) { in connection_cb() function 102 ASSERT(0 == uv_listen((uv_stream_t*) &server_handle, 1, connection_cb)); in TEST_IMPL()
|
D | test-tcp-write-queue-order.c | 86 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 106 ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, connection_cb)); in start_server()
|
D | test-tcp-oob.c | 83 static void connection_cb(uv_stream_t* handle, int status) { in connection_cb() function 125 ASSERT(0 == uv_listen((uv_stream_t*) &server_handle, 1, connection_cb)); in TEST_IMPL()
|
D | test-delayed-accept.c | 78 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb() function 113 r = uv_listen((uv_stream_t*)server, 128, connection_cb); in start_server()
|
D | test-tcp-close-accept.c | 117 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 171 connection_cb)); in TEST_IMPL()
|
D | test-poll-oob.c | 135 static void connection_cb(uv_stream_t* handle, int status) { in connection_cb() function 176 ASSERT(0 == uv_listen((uv_stream_t*) &server_handle, 1, connection_cb)); in TEST_IMPL()
|
D | benchmark-pump.c | 277 static void connection_cb(uv_stream_t* s, int status) { in connection_cb() function 390 r = uv_listen((uv_stream_t*)&tcpServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL() 412 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
D | test-tcp-close-reset.c | 137 static void connection_cb(uv_stream_t* server, int status) { in connection_cb() function 159 r = uv_listen((uv_stream_t*)handle, 128, connection_cb); in start_server()
|
/third_party/pulseaudio/src/pulsecore/ |
D | socket-server.h | 49 …_set_callback(pa_socket_server*s, pa_socket_server_on_connection_cb_t connection_cb, void *userdat…
|
/third_party/libuv/src/win/ |
D | tcp.c | 569 handle->stream.serv.connection_cb = cb; in uv__tcp_listen() 604 handle->stream.serv.connection_cb = cb; in uv__tcp_listen() 1186 if (handle->stream.serv.connection_cb) { in uv__process_tcp_accept_req() 1188 handle->stream.serv.connection_cb((uv_stream_t*)handle, in uv__process_tcp_accept_req() 1202 if (handle->stream.serv.connection_cb) { in uv__process_tcp_accept_req() 1203 handle->stream.serv.connection_cb((uv_stream_t*)handle, 0); in uv__process_tcp_accept_req()
|
/third_party/libuv/include/uv/ |
D | unix.h | 292 uv_connection_cb connection_cb; \
|
D | win.h | 425 uv_connection_cb connection_cb;
|
/third_party/libuv/src/unix/ |
D | pipe.c | 113 handle->connection_cb = cb; in uv__pipe_listen()
|
D | stream.c | 80 stream->connection_cb = NULL; in uv__stream_init() 550 stream->connection_cb(stream, err); in uv__server_io() 556 stream->connection_cb(stream, 0); in uv__server_io()
|
D | tcp.c | 365 tcp->connection_cb = cb; in uv__tcp_listen()
|