Home
last modified time | relevance | path

Searched refs:uv_tcp_t (Results 1 - 25 of 108) sorted by relevance

12345

/third_party/libuv/src/win/
H A Dinternal.h77 int uv__tcp_listen(uv_tcp_t* handle, int backlog, uv_connection_cb cb);
78 int uv__tcp_accept(uv_tcp_t* server, uv_tcp_t* client);
79 int uv__tcp_read_start(uv_tcp_t* handle, uv_alloc_cb alloc_cb,
81 int uv__tcp_write(uv_loop_t* loop, uv_write_t* req, uv_tcp_t* handle,
83 int uv__tcp_try_write(uv_tcp_t* handle, const uv_buf_t bufs[],
86 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
87 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle,
89 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle,
91 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handl
[all...]
H A Dtcp.c40 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) { in uv__tcp_nodelay()
52 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) { in uv__tcp_keepalive()
74 uv_tcp_t* handle, in uv__tcp_set_socket()
146 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* handle, unsigned int flags) { in uv_tcp_init_ex()
195 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle) { in uv_tcp_init()
200 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) { in uv__process_tcp_shutdown_req()
227 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle) { in uv__tcp_endgame()
282 static int uv__tcp_try_bind(uv_tcp_t* handle, in uv__tcp_try_bind()
345 uv_tcp_t* handle; in post_completion()
349 handle = (uv_tcp_t*)re in post_completion()
[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()
/third_party/node/deps/uv/src/win/
H A Dinternal.h75 int uv__tcp_listen(uv_tcp_t* handle, int backlog, uv_connection_cb cb);
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,
79 int uv__tcp_write(uv_loop_t* loop, uv_write_t* req, uv_tcp_t* handle,
81 int uv__tcp_try_write(uv_tcp_t* handle, const uv_buf_t bufs[],
84 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
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* handl
[all...]
H A Dtcp.c48 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) { in uv__tcp_nodelay()
60 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) { in uv__tcp_keepalive()
82 uv_tcp_t* handle, in uv__tcp_set_socket()
154 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* handle, unsigned int flags) { in uv_tcp_init_ex()
203 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle) { in uv_tcp_init()
208 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) { in uv__process_tcp_shutdown_req()
236 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle) { in uv__tcp_endgame()
292 static int uv__tcp_try_bind(uv_tcp_t* handle, in uv__tcp_try_bind()
355 uv_tcp_t* handle; in post_completion()
359 handle = (uv_tcp_t*)re in post_completion()
[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()
/third_party/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 serve in TEST_IMPL()
[all...]
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-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-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*) in test_tcp()
[all...]
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-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-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-oob.c31 static uv_tcp_t server_handle;
32 static uv_tcp_t client_handle;
33 static uv_tcp_t peer_handle;
H A Dtest-tcp-read-stop-start.c25 static uv_tcp_t server;
26 static uv_tcp_t connection;
29 static uv_tcp_t client;
/third_party/libuv/src/unix/
H A Dtcp.c64 static int new_socket(uv_tcp_t* handle, int domain, unsigned int flags) { in new_socket()
85 static int maybe_new_socket(uv_tcp_t* handle, int domain, unsigned int flags) { in maybe_new_socket()
113 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* tcp, unsigned int flags) { in uv_tcp_init_ex()
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()
272 uv_tcp_t* handle, in uv__tcp_connect()
346 int uv_tcp_open(uv_tcp_t* handle, uv_os_sock_t sock) { in uv_tcp_open()
362 int uv_tcp_getsockname(const uv_tcp_t* handle, in uv_tcp_getsockname()
376 int uv_tcp_getpeername(const uv_tcp_t* handle, in uv_tcp_getpeername()
390 int uv_tcp_close_reset(uv_tcp_t* handl
[all...]
/third_party/node/deps/uv/src/unix/
H A Dtcp.c31 static int new_socket(uv_tcp_t* handle, int domain, unsigned long flags) { in new_socket()
67 static int maybe_new_socket(uv_tcp_t* handle, int domain, unsigned long flags) { in maybe_new_socket()
114 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* tcp, unsigned int flags) { in uv_tcp_init_ex()
143 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* tcp) { in uv_tcp_init()
148 int uv__tcp_bind(uv_tcp_t* tcp, in uv__tcp_bind()
206 uv_tcp_t* handle, in uv__tcp_connect()
271 int uv_tcp_open(uv_tcp_t* handle, uv_os_sock_t sock) { in uv_tcp_open()
287 int uv_tcp_getsockname(const uv_tcp_t* handle, in uv_tcp_getsockname()
301 int uv_tcp_getpeername(const uv_tcp_t* handle, in uv_tcp_getpeername()
315 int uv_tcp_close_reset(uv_tcp_t* handl
[all...]
/third_party/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()
/third_party/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()
/third_party/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()
/third_party/libuv/docs/code/dns/
H A Dmain.c54 uv_tcp_t *socket = (uv_tcp_t*) malloc(sizeof(uv_tcp_t)); in on_resolved()
/third_party/node/deps/uvwasi/src/
H A Dfd_table.h14 uv_tcp_t* sock;
39 uv_tcp_t* sock,
54 uv_tcp_t* sock);

Completed in 13 milliseconds

12345