/libuv/src/win/ |
H A D | internal.h | 76 int uv__tcp_accept(uv_tcp_t* server, uv_tcp_t* client); 77 int uv__tcp_read_start(uv_tcp_t* handle, uv_alloc_cb alloc_cb, 81 int uv__tcp_try_write(uv_tcp_t* handle, const uv_buf_t bufs[], 85 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle, 87 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle, 89 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handle, 92 uv_tcp_t* stream, 95 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp); 96 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle); 98 int uv__tcp_xfer_export(uv_tcp_t* handle, [all …]
|
H A D | tcp.c | 357 uv_tcp_t* handle; in post_completion() 361 handle = (uv_tcp_t*)req->data; in post_completion() 376 uv_tcp_t* handle; in post_write_completion() 380 handle = (uv_tcp_t*)req->handle; in post_write_completion() 641 int uv__tcp_accept(uv_tcp_t* server, uv_tcp_t* client) { in uv__tcp_accept() 893 uv_tcp_t* handle, in uv__tcp_write() 958 int uv__tcp_try_write(uv_tcp_t* handle, in uv__tcp_try_write() 1245 int uv__tcp_xfer_export(uv_tcp_t* handle, in uv__tcp_xfer_export() 1280 int uv__tcp_xfer_import(uv_tcp_t* tcp, in uv__tcp_xfer_import() 1535 int uv__tcp_bind(uv_tcp_t* handle, in uv__tcp_bind() [all …]
|
H A D | stream.c | 38 err = uv__tcp_listen((uv_tcp_t*)stream, backlog, cb); in uv_listen() 57 err = uv__tcp_accept((uv_tcp_t*)server, (uv_tcp_t*)client); in uv_accept() 78 err = uv__tcp_read_start((uv_tcp_t*)handle, alloc_cb, read_cb); in uv__read_start() 129 err = uv__tcp_write(loop, req, (uv_tcp_t*) handle, bufs, nbufs, cb); in uv_write() 181 return uv__tcp_try_write((uv_tcp_t*) stream, bufs, nbufs); in uv_try_write()
|
/libuv/test/ |
H A D | test-delayed-accept.c | 49 uv_tcp_t* server; in do_accept() 50 uv_tcp_t* accepted_handle = (uv_tcp_t*)malloc(sizeof *accepted_handle); in do_accept() 59 server = (uv_tcp_t*)timer_handle->data; in do_accept() 102 uv_tcp_t* server = (uv_tcp_t*)malloc(sizeof *server); in start_server() 154 uv_tcp_t* client = (uv_tcp_t*)malloc(sizeof *client); in client_connect()
|
H A D | test-tcp-bind-error.c | 49 uv_tcp_t conn; in TEST_IMPL() 82 uv_tcp_t server1, server2; in TEST_IMPL() 115 uv_tcp_t server; in TEST_IMPL() 140 uv_tcp_t server; in TEST_IMPL() 165 uv_tcp_t server; in TEST_IMPL() 190 uv_tcp_t server; in TEST_IMPL() 216 uv_tcp_t server; in TEST_IMPL() 233 uv_tcp_t server; in TEST_IMPL() 250 uv_tcp_t server; in TEST_IMPL() 264 uv_tcp_t server; in TEST_IMPL() [all …]
|
H A D | test-tcp-close-accept.c | 32 static uv_tcp_t tcp_server; 33 static uv_tcp_t tcp_outgoing[2]; 34 static uv_tcp_t tcp_incoming[ARRAY_SIZE(tcp_outgoing)]; 36 static uv_tcp_t tcp_check; 91 pending_incoming = (uv_tcp_t*) stream - &tcp_incoming[0]; in read_cb() 119 uv_tcp_t* incoming; in connection_cb() 145 uv_tcp_t* client; in TEST_IMPL()
|
H A D | test-tcp-reuseport.c | 35 uv_tcp_t handle; in TEST_IMPL() 59 static uv_tcp_t tcp_connect_handles[MAX_TCP_CLIENTS]; 74 static uv_tcp_t thread_handle1; 75 static uv_tcp_t thread_handle2; 108 uv_tcp_t *client = malloc(sizeof(uv_tcp_t)); in on_connection() 133 static void create_listener(uv_loop_t* loop, uv_tcp_t* handle) { in create_listener() 151 uv_tcp_t* handle; in run_event_loop()
|
H A D | test-tcp-create-socket-early.c | 41 uv_tcp_t* handle; in on_connection() 60 static void tcp_listener(uv_loop_t* loop, uv_tcp_t* server) { in tcp_listener() 77 static void tcp_connector(uv_loop_t* loop, uv_tcp_t* client, uv_connect_t* req) { in tcp_connector() 97 uv_tcp_t client; in TEST_IMPL() 140 uv_tcp_t client; in TEST_IMPL() 186 uv_tcp_t client; in TEST_IMPL() 203 uv_tcp_t client, server; in TEST_IMPL()
|
H A D | test-tcp-close-reset.c | 35 static uv_tcp_t tcp_server; 36 static uv_tcp_t tcp_client; 37 static uv_tcp_t tcp_accepted; 57 static void do_write(uv_tcp_t* handle) { in do_write() 70 static void do_close(uv_tcp_t* handle) { in do_close() 106 ASSERT_PTR_EQ((uv_tcp_t*)stream, &tcp_client); in read_cb2() 149 ASSERT_PTR_EQ((uv_tcp_t*)stream, &tcp_accepted); in read_cb() 170 static void start_server(uv_loop_t* loop, uv_tcp_t* handle) { in start_server() 187 static void do_connect(uv_loop_t* loop, uv_tcp_t* tcp_client) { in do_connect()
|
H A D | test-tcp-bind6-error.c | 39 uv_tcp_t server1, server2; in TEST_IMPL() 76 uv_tcp_t server; in TEST_IMPL() 104 uv_tcp_t server; in TEST_IMPL() 132 uv_tcp_t server; in TEST_IMPL() 161 uv_tcp_t server; in TEST_IMPL()
|
H A D | benchmark-multi-accept.c | 30 uv_tcp_t tcp; 120 ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) &pc->peer_handle)); in ipc_connection_cb() 188 ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) ctx->server_handle)); in ipc_read_cb() 214 ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) &ctx.server_handle)); in send_listen_handles() 215 ASSERT_OK(uv_tcp_bind((uv_tcp_t*) &ctx.server_handle, in send_listen_handles() 301 ASSERT_OK(uv_tcp_init(server_handle->loop, (uv_tcp_t*) storage)); in sv_connection_cb() 354 ASSERT_OK(uv_tcp_init(handle->loop, (uv_tcp_t*) &ctx->client_handle)); in cl_close_cb() 356 (uv_tcp_t*) &ctx->client_handle, in cl_close_cb() 366 uv_tcp_t* handle; in test_tcp() 393 handle = (uv_tcp_t*) &ctx->client_handle; in test_tcp()
|
H A D | test-tcp-write-fail.c | 39 static void close_socket(uv_tcp_t* sock) { in close_socket() 83 close_socket((uv_tcp_t*)stream); in connect_cb() 93 uv_tcp_t client; in TEST_IMPL()
|
H A D | test-tcp-try-write-error.c | 29 static uv_tcp_t server; 30 static uv_tcp_t client; 31 static uv_tcp_t incoming;
|
H A D | test-tcp-close-after-read-timeout.c | 25 static uv_tcp_t client; 26 static uv_tcp_t connection; 122 static void start_server(uv_loop_t* loop, uv_tcp_t* handle) { in start_server() 146 uv_tcp_t tcp_server; in TEST_IMPL()
|
H A D | test-tcp-try-write.c | 31 static uv_tcp_t server; 32 static uv_tcp_t client; 33 static uv_tcp_t incoming;
|
H A D | test-tcp-alloc-cb-fail.c | 29 static uv_tcp_t server; 30 static uv_tcp_t client; 31 static uv_tcp_t incoming;
|
H A D | test-tcp-close.c | 30 static uv_tcp_t tcp_handle; 79 static void start_server(uv_loop_t* loop, uv_tcp_t* handle) { in start_server() 103 uv_tcp_t tcp_server; in TEST_IMPL()
|
H A D | test-tcp-unexpected-read.c | 27 static uv_tcp_t server_handle; 28 static uv_tcp_t client_handle; 29 static uv_tcp_t peer_handle;
|
/libuv/docs/code/cgi/ |
H A D | main.c | 17 void invoke_cgi_script(uv_tcp_t *client) { in invoke_cgi_script() 56 uv_tcp_t *client = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_new_connection() 69 uv_tcp_t server; in main()
|
/libuv/src/unix/ |
H A D | tcp.c | 146 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* tcp) { in uv_tcp_init() 151 int uv__tcp_bind(uv_tcp_t* tcp, in uv__tcp_bind() 278 uv_tcp_t* handle, in uv__tcp_connect() 352 int uv_tcp_open(uv_tcp_t* handle, uv_os_sock_t sock) { in uv_tcp_open() 368 int uv_tcp_getsockname(const uv_tcp_t* handle, in uv_tcp_getsockname() 382 int uv_tcp_getpeername(const uv_tcp_t* handle, in uv_tcp_getpeername() 396 int uv_tcp_close_reset(uv_tcp_t* handle, uv_close_cb close_cb) { in uv_tcp_close_reset() 580 int uv_tcp_nodelay(uv_tcp_t* handle, int on) { in uv_tcp_nodelay() 598 int uv_tcp_keepalive(uv_tcp_t* handle, int on, unsigned int delay) { in uv_tcp_keepalive() 620 int uv_tcp_simultaneous_accepts(uv_tcp_t* handle, int enable) { in uv_tcp_simultaneous_accepts() [all …]
|
/libuv/docs/src/ |
H A D | tcp.rst | 4 :c:type:`uv_tcp_t` --- TCP handle 9 :c:type:`uv_tcp_t` is a 'subclass' of :c:type:`uv_stream_t`. 15 .. c:type:: uv_tcp_t 53 .. c:function:: int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle) 57 .. c:function:: int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* handle, unsigned int flags) 66 .. c:function:: int uv_tcp_open(uv_tcp_t* handle, uv_os_sock_t sock) 76 .. c:function:: int uv_tcp_nodelay(uv_tcp_t* handle, int enable) 80 .. c:function:: int uv_tcp_keepalive(uv_tcp_t* handle, int enable, unsigned int delay) 94 .. c:function:: int uv_tcp_simultaneous_accepts(uv_tcp_t* handle, int enable) 104 .. c:function:: int uv_tcp_bind(uv_tcp_t* handle, const struct sockaddr* addr, unsigned int flags) [all …]
|
/libuv/docs/code/tcp-echo-server/ |
H A D | main.c | 62 uv_tcp_t *client = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_new_connection() 75 uv_tcp_t server; in main()
|
/libuv/docs/code/multi-echo-server/ |
H A D | main.c | 37 uv_tcp_t *client = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_new_connection() 102 uv_tcp_t server; in main()
|
H A D | worker.c | 68 uv_tcp_t *client = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_new_connection()
|
/libuv/docs/code/dns/ |
H A D | main.c | 54 uv_tcp_t *socket = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_resolved()
|