Lines Matching refs:server
65 static void on_connection(uv_stream_t* server, int status) { in on_connection() argument
72 ASSERT_PTR_EQ(&tcp_server, server); in on_connection()
76 r = uv_tcp_init(server->loop, conn); in on_connection()
79 r = uv_accept(server, (uv_stream_t*)conn); in on_connection()
83 uv_close((uv_handle_t*)server, NULL); in on_connection()
473 uv_tcp_t server; in TEST_IMPL() local
479 r = uv_tcp_init(uv_default_loop(), &server); in TEST_IMPL()
482 r = uv_tcp_bind(&server, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
485 r = uv_tcp_simultaneous_accepts(&server, 1); in TEST_IMPL()
488 r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); in TEST_IMPL()
490 ASSERT_EQ(32, server.reqs_pending); in TEST_IMPL()
498 uv_tcp_t server; in TEST_IMPL() local
504 r = uv_tcp_init(uv_default_loop(), &server); in TEST_IMPL()
507 r = uv_tcp_bind(&server, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
510 r = uv_tcp_simultaneous_accepts(&server, 0); in TEST_IMPL()
513 r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); in TEST_IMPL()
515 ASSERT_EQ(1, server.reqs_pending); in TEST_IMPL()
609 static void ipc_on_connection(uv_stream_t* server, int status) { in ipc_on_connection() argument
619 ASSERT_PTR_EQ(&tcp_server, server); in ipc_on_connection()
621 r = uv_tcp_init(server->loop, &conn.conn); in ipc_on_connection()
624 r = uv_accept(server, (uv_stream_t*)&conn.conn); in ipc_on_connection()
644 static void ipc_on_connection_tcp_conn(uv_stream_t* server, int status) { in ipc_on_connection_tcp_conn() argument
650 ASSERT_PTR_EQ(&tcp_server, server); in ipc_on_connection_tcp_conn()
655 r = uv_tcp_init(server->loop, conn); in ipc_on_connection_tcp_conn()
658 r = uv_accept(server, (uv_stream_t*)conn); in ipc_on_connection_tcp_conn()
