| /aosp_15_r20/external/perfetto/src/traced_relay/ |
| H A D | relay_service_unittest.cc | 70 auto tcp_server = base::UnixSocket::Listen( in TEST() local
73 ASSERT_TRUE(tcp_server->is_listening()); in TEST()
74 auto tcp_sock_name = tcp_server->GetSockAddr(); in TEST()
173 auto tcp_server = base::UnixSocket::Listen( in TEST() local
176 ASSERT_TRUE(tcp_server->is_listening()); in TEST()
177 auto tcp_sock_name = tcp_server->GetSockAddr(); in TEST()
209 tcp_server->Shutdown(true); in TEST()
223 auto tcp_server = base::UnixSocket::Listen( in TEST() local
226 ASSERT_TRUE(tcp_server->is_listening()); in TEST()
227 auto tcp_sock_name = tcp_server->GetSockAddr(); in TEST()
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/test/latency/ |
| D | tcp_server.cpp | 25 class tcp_server : boost::asio::coroutine class
28 tcp_server(tcp::acceptor& acceptor, std::size_t buf_size) : in tcp_server() function in tcp_server
61 explicit ref(tcp_server* p) in ref()
72 tcp_server* p_;
101 std::vector<boost::shared_ptr<tcp_server> > servers; in main()
105 boost::shared_ptr<tcp_server> s(new tcp_server(acceptor, buf_size)); in main()
|
| D | Jamfile.v2 | 33 exe tcp_server : tcp_server.cpp ;
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/example/cpp03/tutorial/daytime3/ |
| D | server.cpp | 69 class tcp_server class
72 tcp_server(boost::asio::io_context& io_context) in tcp_server() function in tcp_server
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
110 tcp_server server(io_context); in main()
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/example/cpp03/tutorial/daytime7/ |
| D | server.cpp | 68 class tcp_server class
71 tcp_server(boost::asio::io_context& io_context) in tcp_server() function in tcp_server
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
150 tcp_server server1(io_context); in main()
|
| /aosp_15_r20/external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_ssl.py | 97 def tcp_server(self, server_prog, *, member in TestSSL
145 return self.tcp_server(*args, family=socket.AF_UNIX, **kwargs)
370 with self.tcp_server(server,
410 with self.tcp_server(server,
450 with self.tcp_server(server,
487 with self.tcp_server(server,
533 with self.tcp_server(server,
670 with self.tcp_server(server,
734 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
793 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
[all …]
|
| D | test_sslproto.py | 279 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
342 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
439 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
500 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
634 with self.tcp_server(server,
674 with self.tcp_server(server,
712 with self.tcp_server(server,
754 with self.tcp_server(server,
|
| D | functional.py | 45 def tcp_server(self, server_prog, *, member in FunctionalTestCaseMixin
87 return self.tcp_server(*args, family=socket.AF_UNIX, **kwargs)
|
| /aosp_15_r20/external/grpc-grpc/test/core/util/ |
| H A D | reconnect_server.cc | 97 test_tcp_server_init(&server->tcp_server, on_connect, server); in reconnect_server_init()
105 test_tcp_server_start(&server->tcp_server, port); in reconnect_server_start()
109 test_tcp_server_poll(&server->tcp_server, 1000 * seconds); in reconnect_server_poll()
126 test_tcp_server_destroy(&server->tcp_server); in reconnect_server_destroy()
|
| H A D | test_tcp_server.cc | 84 server->on_connect, server->cb_data, &server->tcp_server); in test_tcp_server_start()
87 grpc_tcp_server_add_port(server->tcp_server, &resolved_addr, &port_added); in test_tcp_server_start()
91 grpc_tcp_server_start(server->tcp_server, &server->pollset); in test_tcp_server_start()
115 grpc_tcp_server_unref(server->tcp_server); in test_tcp_server_destroy()
|
| H A D | test_tcp_server.h | 33 grpc_tcp_server* tcp_server = nullptr; member
|
| H A D | reconnect_server.h | 34 test_tcp_server tcp_server; member
|
| /aosp_15_r20/external/python/bumble/examples/ |
| D | run_rfcomm_server.py | 42 def on_rfcomm_session(rfcomm_session, tcp_server): argument
44 tcp_server.attach_session(rfcomm_session)
137 tcp_server = TcpServer(tcp_port)
144 lambda session: on_rfcomm_session(session, tcp_server)
|
| D | run_rfcomm_client.py | 155 async def tcp_server(tcp_port, rfcomm_session): function
232 asyncio.create_task(tcp_server(tcp_port, session))
|
| /aosp_15_r20/packages/modules/Bluetooth/tools/rootcanal/desktop/ |
| D | test_environment.cc | 87 rootcanal::configuration::TcpServer const& tcp_server = config->tcp_server(index); in TestEnvironment() local
88 SetUpHciServer(open_server, tcp_server.tcp_port(), in TestEnvironment()
89 rootcanal::ControllerProperties(tcp_server.configuration())); in TestEnvironment()
|
| /aosp_15_r20/external/autotest/site_utils/ |
| H A D | log_socket_server.py | 159 tcp_server = LogRecordSocketReceiver()
162 port.value = tcp_server.port
163 tcp_server.serve_until_stopped()
|
| H A D | rpc_logserver.py | 73 tcp_server = log_socket_server.LogRecordSocketReceiver(
77 tcp_server.serve_until_stopped()
|
| /aosp_15_r20/tools/netsim/rust/proto/src/ |
| H A D | configuration.rs | 1157 pub tcp_server: ::std::vec::Vec<TcpServer>, field
1179 |m: &Configuration| { &m.tcp_server }, in generated_message_descriptor_data()
1180 |m: &mut Configuration| { &mut m.tcp_server }, in generated_message_descriptor_data()
1194 for v in &self.tcp_server { in is_initialized()
1206 self.tcp_server.push(is.read_message()?); in merge_from()
1220 for value in &self.tcp_server { in compute_size()
1230 for v in &self.tcp_server { in write_to_with_cached_sizes()
1250 self.tcp_server.clear(); in clear()
1256 tcp_server: ::std::vec::Vec::new(), in default_instance()
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/doc/ |
| D | tutorial.qbk | 1193 ``''''''`` tcp_server server(io_context);
1213 [heading The tcp_server class]
1216 ``''''''``class tcp_server
1225 ``''''''`` tcp_server(boost::asio::io_context& io_context)
1245 ``''''''`` boost::bind(&tcp_server::handle_accept, this, new_connection,
1440 ``''''''``class tcp_server
1443 ``''''''`` tcp_server(boost::asio::io_context& io_context)
1457 ``''''''`` boost::bind(&tcp_server::handle_accept, this, new_connection,
1481 ``''''''`` tcp_server server(io_context);
2056 ``''''''`` tcp_server server1(io_context);
[all …]
|
| /aosp_15_r20/external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sockmap_ktls.c | 13 static int tcp_server(int family) in tcp_server() function
42 srv = tcp_server(family); in test_sockmap_ktls_disconnect_after_delete()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/mio/ |
| D | Cargo.toml | 91 name = "tcp_server"
92 path = "examples/tcp_server.rs"
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/example/cpp03/tutorial/ |
| D | daytime_dox.txt | 153 \until tcp_server
161 \section tutdaytime3classtcp_server The tcp_server class
164 \skip class tcp_server
459 \until tcp_server
470 \section tutdaytime7classtcp The tcp_connection and tcp_server classes
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 894 grpc_tcp_server* tcp_server; in Orphan() local
907 tcp_server = tcp_server_; in Orphan()
909 grpc_tcp_server_shutdown_listeners(tcp_server); in Orphan()
910 grpc_tcp_server_unref(tcp_server); in Orphan()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/server/ |
| H A D | chttp2_server.cc | 929 grpc_tcp_server* tcp_server; in Orphan() local
942 tcp_server = tcp_server_; in Orphan()
944 grpc_tcp_server_shutdown_listeners(tcp_server); in Orphan()
945 grpc_tcp_server_unref(tcp_server); in Orphan()
|
| /aosp_15_r20/external/python/cpython3/Lib/test/ |
| D | test_largefile.py | 203 def tcp_server(self, sock): member in TestSocketSendfile
228 self.tcp_server(sock)
|