Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 16 of 16) sorted by relevance

/libuv/test/
H A Dblackhole-server.c43 conn_rec* conn; in connection_cb() local
49 conn = malloc(sizeof *conn); in connection_cb()
50 ASSERT_NOT_NULL(conn); in connection_cb()
52 r = uv_tcp_init(stream->loop, &conn->handle); in connection_cb()
55 r = uv_accept(stream, (uv_stream_t*)&conn->handle); in connection_cb()
73 conn_rec* conn; in read_cb() local
81 conn = container_of(stream, conn_rec, handle); in read_cb()
83 r = uv_shutdown(&conn->shutdown_req, stream, shutdown_cb); in read_cb()
90 uv_close((uv_handle_t*)&conn->handle, close_cb); in shutdown_cb()
95 conn_rec* conn = container_of(handle, conn_rec, handle); in close_cb() local
[all …]
H A Dtest-ipc.c74 conn = malloc(sizeof(*conn)); in on_connection()
125 conn = malloc(sizeof(*conn)); in make_many_connections()
128 r = uv_tcp_init(uv_default_loop(), &conn->conn); in make_many_connections()
133 (uv_tcp_t*) &conn->conn, in make_many_connections()
138 conn->conn.data = conn; in make_many_connections()
557 ASSERT_PTR_EQ(&conn.conn, req->handle); in tcp_connection_write_cb()
621 r = uv_tcp_init(server->loop, &conn.conn); in ipc_on_connection()
627 uv_close((uv_handle_t*)&conn.conn, close_cb); in ipc_on_connection()
652 conn = malloc(sizeof(*conn)); in ipc_on_connection_tcp_conn()
759 r = uv_tcp_init(uv_default_loop(), &conn.conn); in ipc_helper_tcp_connection()
[all …]
H A Dtest-tcp-shutdown-after-write.c28 static uv_tcp_t conn; variable
43 if (handle == (uv_handle_t*)&conn) in close_cb()
68 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in timer_cb()
71 r = uv_shutdown(&shutdown_req, (uv_stream_t*)&conn, shutdown_cb); in timer_cb()
86 r = uv_read_start((uv_stream_t*)&conn, alloc_cb, read_cb); in connect_cb()
100 uv_close((uv_handle_t*)&conn, close_cb); in shutdown_cb()
118 r = uv_tcp_init(loop, &conn); in TEST_IMPL()
122 &conn, in TEST_IMPL()
H A Dtest-tcp-connect-timeout.c33 static uv_tcp_t conn; variable
49 uv_close((uv_handle_t*)&conn, close_cb); in timer_cb()
55 ASSERT(handle == (uv_handle_t*)&conn || handle == (uv_handle_t*)&timer); in close_cb()
75 r = uv_tcp_init(uv_default_loop(), &conn); in TEST_IMPL()
79 &conn, in TEST_IMPL()
142 r = uv_tcp_init(uv_default_loop(), &conn); in TEST_IMPL()
146 &conn, in TEST_IMPL()
180 r = uv_tcp_init(uv_default_loop(), &conn); in TEST_IMPL()
184 &conn, in TEST_IMPL()
H A Dtest-pipe-connect-multiple.c46 uv_pipe_t* conn; in connection_cb() local
49 conn = &connections[connection_cb_called]; in connection_cb()
50 r = uv_pipe_init(server->loop, conn, 0); in connection_cb()
53 r = uv_accept(server, (uv_stream_t*)conn); in connection_cb()
112 uv_pipe_t* conn; in connection_cb2() local
115 conn = &connections[connection_cb_called]; in connection_cb2()
116 r = uv_pipe_init(server->loop, conn, 0); in connection_cb2()
119 r = uv_accept(server, (uv_stream_t*)conn); in connection_cb2()
122 uv_close((uv_handle_t*)conn, NULL); in connection_cb2()
H A Dtest-tcp-connect-error-after-write.c66 uv_tcp_t conn; in TEST_IMPL()
73 r = uv_tcp_init(uv_default_loop(), &conn); in TEST_IMPL()
76 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
80 &conn, in TEST_IMPL()
85 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
H A Dbenchmark-pound.c37 typedef void (*make_connect_fn)(struct conn_rec_s* conn);
104 conn_rec* conn; in connect_cb() local
120 conn = (conn_rec*)req->data; in connect_cb()
121 ASSERT_NOT_NULL(conn); in connect_cb()
124 printf("connect_cb %d\n", conn->i); in connect_cb()
127 r = uv_read_start(&conn->stream, alloc_cb, read_cb); in connect_cb()
133 r = uv_write(&conn->write_req, &conn->stream, &buf, 1, after_write); in connect_cb()
H A Dtest-tcp-bind-error.c49 uv_tcp_t conn; in TEST_IMPL() local
56 ASSERT_OK(uv_tcp_init(uv_default_loop(), &conn)); in TEST_IMPL()
58 ASSERT_OK(uv_tcp_bind(&conn, (const struct sockaddr*) &addr, 0)); in TEST_IMPL()
62 &conn, in TEST_IMPL()
67 ASSERT_EQ(UV_EADDRINUSE, uv_tcp_getsockname(&conn, in TEST_IMPL()
/libuv/src/win/
H A Dpipe.c120 handle->pipe.conn.ipc_remote_pid = 0; in uv_pipe_init()
123 handle->pipe.conn.ipc_xfer_queue_length = 0; in uv_pipe_init()
135 handle->pipe.conn.eof_timer = NULL; in uv__pipe_connection_init()
1723 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
2300 handle->stream.conn.shutdown_req = NULL; in uv__process_pipe_shutdown_req()
2342 pipe->pipe.conn.eof_timer = (uv_timer_t*) uv__malloc(sizeof *pipe->pipe.conn.eof_timer); in eof_timer_init()
2347 pipe->pipe.conn.eof_timer->data = pipe; in eof_timer_init()
2355 if (pipe->pipe.conn.eof_timer != NULL) { in eof_timer_start()
2364 if (pipe->pipe.conn.eof_timer != NULL) { in eof_timer_stop()
2407 if (pipe->pipe.conn.eof_timer) { in eof_timer_destroy()
[all …]
H A Dstream-inl.h39 handle->stream.conn.shutdown_req = NULL; in uv__stream_init()
40 handle->stream.conn.write_reqs_pending = 0; in uv__stream_init()
H A Dtcp.c169 handle->tcp.conn.func_connectex = NULL; in uv_tcp_init_ex()
210 assert(stream->stream.conn.write_reqs_pending == 0); in uv__process_tcp_shutdown_req()
214 stream->stream.conn.shutdown_req = NULL; in uv__process_tcp_shutdown_req()
802 if (!handle->tcp.conn.func_connectex) { in uv__tcp_try_connect()
927 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
934 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
948 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
964 if (handle->stream.conn.write_reqs_pending > 0) in uv__tcp_try_write()
1142 handle->stream.conn.write_reqs_pending--; in uv__process_tcp_write_req()
1143 if (handle->stream.conn.write_reqs_pending == 0) { in uv__process_tcp_write_req()
[all …]
H A Dstream.c217 handle->stream.conn.shutdown_req = req; in uv_shutdown()
221 if (handle->stream.conn.write_reqs_pending == 0) { in uv_shutdown()
H A Dtty.c2185 handle->stream.conn.write_reqs_pending++;
2207 if (handle->stream.conn.write_reqs_pending > 0)
2230 handle->stream.conn.write_reqs_pending--;
2231 if (handle->stream.conn.write_reqs_pending == 0 &&
2235 handle->stream.conn.shutdown_req);
2262 assert(stream->stream.conn.write_reqs_pending == 0);
2265 stream->stream.conn.shutdown_req = NULL;
H A Dprocess.c1113 ((uv_pipe_t*) fdopt->data.stream)->pipe.conn.ipc_remote_pid = in uv_spawn()
/libuv/include/uv/
H A Dwin.h441 struct { uv_stream_connection_fields } conn; \
460 struct { uv_tcp_connection_fields } conn; \
500 struct { uv_pipe_connection_fields } conn; \
/libuv/src/
H A Duv-common.h272 (h->stream.conn.shutdown_req != NULL)

Completed in 44 milliseconds