| /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 ;
|
| /external/perfetto/src/traced_relay/ |
| 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()
|
| /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()
|
| /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()
|
| /external/grpc-grpc/test/core/util/ |
| 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()
|
| 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()
|
| D | test_tcp_server.h | 33 grpc_tcp_server* tcp_server = nullptr; member
|
| D | reconnect_server.h | 34 test_tcp_server tcp_server; member
|
| /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))
|
| /external/autotest/site_utils/ |
| D | log_socket_server.py | 159 tcp_server = LogRecordSocketReceiver()
162 port.value = tcp_server.port
163 tcp_server.serve_until_stopped()
|
| D | rpc_logserver.py | 73 tcp_server = log_socket_server.LogRecordSocketReceiver(
77 tcp_server.serve_until_stopped()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_ssl.py | 100 def tcp_server(self, server_prog, *, member in TestSSL
148 return self.tcp_server(*args, family=socket.AF_UNIX, **kwargs)
373 with self.tcp_server(server,
413 with self.tcp_server(server,
453 with self.tcp_server(server,
490 with self.tcp_server(server,
536 with self.tcp_server(server,
673 with self.tcp_server(server,
737 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
796 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
[all …]
|
| D | test_sslproto.py | 341 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
404 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
502 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
563 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
698 with self.tcp_server(server,
738 with self.tcp_server(server,
776 with self.tcp_server(server,
818 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)
|
| /external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| 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()
|
| /external/rust/android-crates-io/crates/mio/ |
| D | Cargo.toml | 91 name = "tcp_server"
92 path = "examples/tcp_server.rs"
|
| /external/python/bumble/tests/ |
| D | transport_tcp_server_test.py | 22 from bumble.transport.tcp_server import (
|
| /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 …]
|
| /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
|
| /external/python/bumble/bumble/transport/ |
| D | __init__.py | 126 from .tcp_server import open_tcp_server_transport
|
| /external/python/cpython3/Lib/test/ |
| D | test_largefile.py | 222 def tcp_server(self, sock): member in TestSocketSendfile
248 self.tcp_server(sock)
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/server/ |
| 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()
|
| /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()
|