Home
last modified time | relevance | path

Searched refs:uv_tcp_t (Results 1 – 25 of 87) sorted by relevance

1234

/libuv/src/win/
H A Dinternal.h76 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 Dtcp.c357 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 Dstream.c38 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 Dtest-delayed-accept.c49 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 Dtest-tcp-bind-error.c49 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 Dtest-tcp-close-accept.c32 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 Dtest-tcp-reuseport.c35 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 Dtest-tcp-create-socket-early.c41 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 Dtest-tcp-close-reset.c35 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 Dtest-tcp-bind6-error.c39 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 Dbenchmark-multi-accept.c30 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 Dtest-tcp-write-fail.c39 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 Dtest-tcp-try-write-error.c29 static uv_tcp_t server;
30 static uv_tcp_t client;
31 static uv_tcp_t incoming;
H A Dtest-tcp-close-after-read-timeout.c25 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 Dtest-tcp-try-write.c31 static uv_tcp_t server;
32 static uv_tcp_t client;
33 static uv_tcp_t incoming;
H A Dtest-tcp-alloc-cb-fail.c29 static uv_tcp_t server;
30 static uv_tcp_t client;
31 static uv_tcp_t incoming;
H A Dtest-tcp-close.c30 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 Dtest-tcp-unexpected-read.c27 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 Dmain.c17 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 Dtcp.c146 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 Dtcp.rst4 :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 Dmain.c62 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 Dmain.c37 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 Dworker.c68 uv_tcp_t *client = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_new_connection()
/libuv/docs/code/dns/
H A Dmain.c54 uv_tcp_t *socket = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_resolved()

Completed in 46 milliseconds

1234