Home
last modified time | relevance | path

Searched refs:server_socket (Results 1 – 25 of 49) sorted by relevance

12

/external/cronet/tot/net/socket/
Dunix_domain_server_socket_posix_unittest.cc62 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
65 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
70 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
73 EXPECT_THAT(server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1), in TEST_F()
77 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
83 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
86 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
87 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
96 UnixDomainServerSocket server_socket(CreateAuthCallback(false), in TEST_F() local
98 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
[all …]
Dunix_domain_client_socket_posix_unittest.cc147 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
149 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
154 server_socket.Accept(&accepted_socket, accept_callback.callback())); in TEST_F()
173 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
175 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
180 server_socket.AcceptSocketDescriptor(&accepted_socket_fd, in TEST_F()
225 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
227 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
232 server_socket.Accept(&accepted_socket, accept_callback.callback())); in TEST_F()
276 UnixDomainServerSocket server_socket(CreateAuthCallback(true), false); in TEST_F() local
[all …]
Dtcp_client_socket_unittest.cc87 std::unique_ptr<TCPServerSocket> server_socket = in CreateConnectedSockets() local
89 ASSERT_THAT(server_socket->Listen(IPEndPoint(local_address, 0), 1, in CreateConnectedSockets()
93 ASSERT_THAT(server_socket->GetLocalAddress(&server_address), IsOk()); in CreateConnectedSockets()
110 server_socket->Accept(accepted_socket, accept_callback.callback()); in CreateConnectedSockets()
119 *server_socket_opt = std::move(server_socket); in CreateConnectedSockets()
624 std::unique_ptr<ServerSocket> server_socket; in TEST_P() local
625 CreateConnectedSockets(&accepted_socket, &client_socket, &server_socket); in TEST_P()
658 server_socket->Accept(&accepted_socket, accept_callback.callback()); in TEST_P()
739 std::unique_ptr<ServerSocket> server_socket; in TEST_P() local
740 CreateConnectedSockets(&accepted_socket, &client_socket, &server_socket); in TEST_P()
[all …]
/external/cronet/stable/net/socket/
Dunix_domain_server_socket_posix_unittest.cc62 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
65 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
70 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
73 EXPECT_THAT(server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1), in TEST_F()
77 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
83 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
86 server_socket.BindAndListen(kInvalidSocketPath, /*backlog=*/1)); in TEST_F()
87 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
96 UnixDomainServerSocket server_socket(CreateAuthCallback(false), in TEST_F() local
98 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
[all …]
Dunix_domain_client_socket_posix_unittest.cc147 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
149 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
154 server_socket.Accept(&accepted_socket, accept_callback.callback())); in TEST_F()
173 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
175 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
180 server_socket.AcceptSocketDescriptor(&accepted_socket_fd, in TEST_F()
225 UnixDomainServerSocket server_socket(CreateAuthCallback(true), in TEST_F() local
227 EXPECT_THAT(server_socket.BindAndListen(socket_path_, /*backlog=*/1), IsOk()); in TEST_F()
232 server_socket.Accept(&accepted_socket, accept_callback.callback())); in TEST_F()
276 UnixDomainServerSocket server_socket(CreateAuthCallback(true), false); in TEST_F() local
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dquic_udp_socket_test.cc35 SocketFd server_socket = in TEST_F() local
37 ASSERT_NE(kQuicInvalidSocketFd, server_socket); in TEST_F()
38 ASSERT_TRUE(socket_api.Bind(server_socket, any_address)); in TEST_F()
40 ASSERT_EQ(0, server_address.FromSocket(server_socket)); in TEST_F()
63 socket_api.ReadPacket(server_socket, packet_info_interested, &read_result); in TEST_F()
71 write_result = socket_api.WritePacket(server_socket, server_data.data(), in TEST_F()
88 SocketFd server_socket = in TEST_F() local
90 ASSERT_NE(kQuicInvalidSocketFd, server_socket); in TEST_F()
91 ASSERT_TRUE(socket_api.Bind(server_socket, any_address)); in TEST_F()
93 ASSERT_EQ(0, server_address.FromSocket(server_socket)); in TEST_F()
[all …]
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dquic_udp_socket_test.cc35 SocketFd server_socket = in TEST_F() local
37 ASSERT_NE(kQuicInvalidSocketFd, server_socket); in TEST_F()
38 ASSERT_TRUE(socket_api.Bind(server_socket, any_address)); in TEST_F()
40 ASSERT_EQ(0, server_address.FromSocket(server_socket)); in TEST_F()
63 socket_api.ReadPacket(server_socket, packet_info_interested, &read_result); in TEST_F()
71 write_result = socket_api.WritePacket(server_socket, server_data.data(), in TEST_F()
88 SocketFd server_socket = in TEST_F() local
90 ASSERT_NE(kQuicInvalidSocketFd, server_socket); in TEST_F()
91 ASSERT_TRUE(socket_api.Bind(server_socket, any_address)); in TEST_F()
93 ASSERT_EQ(0, server_address.FromSocket(server_socket)); in TEST_F()
[all …]
/external/perfetto/src/bigtrace/orchestrator/
Dorchestrator_main.cc42 std::string server_socket; member
99 command_line_options.server_socket = optarg; in ParseCommandLineOptions()
149 std::string server_socket = options->server_socket.empty() in OrchestratorMain() local
151 : options->server_socket; in OrchestratorMain()
195 builder.AddListeningPort(server_socket, grpc::InsecureServerCredentials()); in OrchestratorMain()
198 PERFETTO_LOG("Orchestrator server listening on %s", server_socket.c_str()); in OrchestratorMain()
/external/sdv/vsomeip/third_party/boost/asio/test/
Dbuffered_write_stream.cpp157 stream_type server_socket(io_context); in test_sync_operations() local
158 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
178 bytes_read += server_socket.read_some( in test_sync_operations()
189 bytes_written += server_socket.write_some( in test_sync_operations()
191 server_socket.flush(); in test_sync_operations()
205 server_socket.close(); in test_sync_operations()
275 stream_type server_socket(io_context); in test_async_operations() local
276 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
304 server_socket.async_read_some( in test_async_operations()
318 server_socket.async_write_some( in test_async_operations()
[all …]
Dbuffered_stream.cpp168 stream_type server_socket(io_context); in test_sync_operations() local
169 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
189 bytes_read += server_socket.read_some( in test_sync_operations()
200 bytes_written += server_socket.write_some( in test_sync_operations()
202 server_socket.flush(); in test_sync_operations()
216 server_socket.close(); in test_sync_operations()
286 stream_type server_socket(io_context); in test_async_operations() local
287 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
315 server_socket.async_read_some( in test_async_operations()
329 server_socket.async_write_some( in test_async_operations()
[all …]
Dbuffered_read_stream.cpp157 stream_type server_socket(io_context); in test_sync_operations() local
158 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
177 bytes_read += server_socket.read_some( in test_sync_operations()
188 bytes_written += server_socket.write_some( in test_sync_operations()
203 server_socket.close(); in test_sync_operations()
268 stream_type server_socket(io_context); in test_async_operations() local
269 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
293 server_socket.async_read_some( in test_async_operations()
307 server_socket.async_write_some( in test_async_operations()
328 server_socket.close(); in test_async_operations()
/external/grpc-grpc/test/core/event_engine/posix/
Dposix_event_engine_connect_test.cc67 int server_socket; in CreateConnectedSockets() local
74 if ((server_socket = socket(AF_INET6, SOCK_STREAM, 0)) <= 0) { in CreateConnectedSockets()
80 if (setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) { in CreateConnectedSockets()
84 if (setsockopt(server_socket, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt))) { in CreateConnectedSockets()
90 if (bind(server_socket, resolved_addr.address(), resolved_addr.size()) < 0) { in CreateConnectedSockets()
96 if (listen(server_socket, 1) < 0) { in CreateConnectedSockets()
99 ret_sockets.push_back(server_socket); in CreateConnectedSockets()
/external/webrtc/examples/stunserver/
Dstunserver_main.cc34 rtc::AsyncUDPSocket* server_socket = in main() local
36 if (!server_socket) { in main()
41 StunServer* server = new StunServer(server_socket); in main()
/external/python/pyserial/examples/
Dport_publisher.py113 self.server_socket = None
140 self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
141 self.server_socket.setsockopt(
144 self.server_socket.getsockopt(
149 self.server_socket.setblocking(0)
151 self.server_socket.bind(('', self.network_port))
152 self.server_socket.listen(1)
171 if self.server_socket:
172 self.server_socket.close()
211 read_map[self.server_socket] = self.handle_connect
[all …]
/external/pigweed/pw_system/
Dsocket_target_io.cc33 static stream::ServerSocket server_socket; in GetStream() local
38 PW_CHECK_OK(server_socket.Listen(kPort)); in GetStream()
46 auto accept_result = server_socket.Accept(); in GetStream()
/external/grpc-grpc/test/core/handshake/
Dclient_ssl.cc302 int server_socket = -1; in client_ssl_test() local
304 while (server_socket == -1 && socket_retries-- > 0) { in client_ssl_test()
305 server_socket = create_socket(&port); in client_ssl_test()
306 if (server_socket == -1) { in client_ssl_test()
310 EXPECT_GT(server_socket, 0); in client_ssl_test()
315 server_args args = {server_socket, server_alpn_preferred, &ssl_library_info}; in client_ssl_test()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/test_app/
Dserver_app.py147 server_socket = self.channelz.find_server_socket_matching_client(
149 if not server_socket:
156 self.channelz.sock_addresses_pretty(server_socket),
158 return server_socket
/external/pigweed/pw_stream/public/pw_stream/
Dsocket_stream.h165 explicit SocketOwnership(ServerSocket* server_socket) in SocketOwnership() argument
166 : server_socket_(server_socket) { in SocketOwnership()
168 std::lock_guard lock(server_socket->socket_mutex_); in SocketOwnership()
169 pipe_r_fd_ = server_socket->socket_pipe_r_fd_; in SocketOwnership()
/external/pigweed/targets/host/
Dsystem_rpc_server.cc39 stream::ServerSocket server_socket; variable
68 PW_CHECK_OK(server_socket.Listen(socket_port)); in Init()
69 auto accept_result = server_socket.Accept(); in Init()
/external/cronet/tot/net/server/
Dhttp_server_fuzzer.cc119 std::unique_ptr<net::ServerSocket> server_socket( in LLVMFuzzerTestOneInput() local
123 server_socket->ListenWithAddressAndPort("127.0.0.1", 80, 5)); in LLVMFuzzerTestOneInput()
127 net::HttpServer server(std::move(server_socket), &delegate); in LLVMFuzzerTestOneInput()
/external/cronet/stable/net/server/
Dhttp_server_fuzzer.cc119 std::unique_ptr<net::ServerSocket> server_socket( in LLVMFuzzerTestOneInput() local
123 server_socket->ListenWithAddressAndPort("127.0.0.1", 80, 5)); in LLVMFuzzerTestOneInput()
127 net::HttpServer server(std::move(server_socket), &delegate); in LLVMFuzzerTestOneInput()
/external/sandboxed-api/sandboxed_api/sandbox2/network_proxy/
Dtesting.h42 sapi::file_util::fileops::FDCloser server_socket, in NetworkProxyTestServer() argument
45 server_socket_(std::move(server_socket)), in NetworkProxyTestServer()
Dtesting.cc82 SAPI_ASSIGN_OR_RETURN(FDCloser server_socket, CreateServerSocket(port, ipv6)); in Start()
84 port, std::move(server_socket), std::move(event_fd))); in Start()
/external/rust/android-crates-io/crates/tokio/tests/
Duds_socket.rs19 let server_socket = { in datagram_echo_server() localVariable
28 let (len, peer_addr) = server_socket.recv_from(&mut recv_buf[..]).await?; in datagram_echo_server()
30 server_socket.send_to(&recv_buf[..len], path).await?; in datagram_echo_server()
/external/perfetto/src/traced_relay/
Drelay_service_integrationtest.cc42 std::unique_ptr<base::UnixSocket> server_socket; member
135 param.server_socket = base::UnixSocket::Listen( in TEST()
138 ASSERT_TRUE(param.server_socket->is_listening()); in TEST()
139 param.tcp_sock_name = param.server_socket->GetSockAddr(); in TEST()
150 param.server_socket = nullptr; in TEST()

12