| /third_party/nghttp2/src/ |
| D | asio_server.cc | 65 for (auto &acceptor : acceptors_) { in listen_and_serve() local
67 start_accept(*tls_context, acceptor, mux); in listen_and_serve()
69 start_accept(acceptor, mux); in listen_and_serve()
93 auto acceptor = tcp::acceptor(io_service_pool_.get_io_service()); in bind_and_listen() local
95 if (acceptor.open(endpoint.protocol(), ec)) { in bind_and_listen()
99 acceptor.set_option(tcp::acceptor::reuse_address(true)); in bind_and_listen()
101 if (acceptor.bind(endpoint, ec)) { in bind_and_listen()
105 if (acceptor.listen( in bind_and_listen()
111 acceptors_.push_back(std::move(acceptor)); in bind_and_listen()
126 tcp::acceptor &acceptor, serve_mux &mux) { in start_accept() argument
[all …]
|
| /third_party/boost/libs/asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr;
31 connection_iter(tcp::acceptor& a, tcp::socket s) in connection_iter()
58 tcp::acceptor& acceptor_;
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
76 awaitable<void> listener(tcp::acceptor acceptor) in listener() argument
78 for co_await (tcp::socket s : connections(acceptor)) in listener()
93 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in main() local
94 co_spawn(io_context, listener(std::move(acceptor)), detached); in main()
|
| /third_party/boost/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr;
31 connection_iter(tcp::acceptor& a, tcp::socket s) in connection_iter()
58 tcp::acceptor& acceptor_;
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
76 awaitable<void> listener(tcp::acceptor acceptor) in listener() argument
78 for co_await (tcp::socket s : connections(acceptor)) in listener()
93 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in main() local
94 co_spawn(io_context, listener(std::move(acceptor)), detached); in main()
|
| /third_party/boost/libs/beast/test/doc/ |
| D | websocket_1_connecting.cpp | 46 net::ip::tcp::acceptor acceptor(ioc); in snippets() local
47 acceptor.bind(net::ip::tcp::endpoint(net::ip::tcp::v4(), 0)); in snippets()
48 acceptor.listen(); in snippets()
53 stream<tcp_stream> ws(acceptor.accept()); in snippets()
59 net::ip::tcp::acceptor acceptor(ioc); in snippets() local
69 acceptor.accept(get_lowest_layer(ws).socket()); in snippets()
|
| /third_party/boost/libs/asio/test/latency/ |
| D | tcp_server.cpp | 28 tcp_server(tcp::acceptor& acceptor, std::size_t buf_size) : in tcp_server() argument
29 acceptor_(acceptor), in tcp_server()
76 tcp::acceptor& acceptor_;
100 tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), port)); in main() local
105 boost::shared_ptr<tcp_server> s(new tcp_server(acceptor, buf_size)); in main()
|
| /third_party/boost/doc/html/boost_asio/example/cpp14/operations/ |
| D | composed_1.cpp | 58 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
59 tcp::socket socket = acceptor.accept(); in test_callback()
84 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
85 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_2.cpp | 76 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
77 tcp::socket socket = acceptor.accept(); in test_callback()
102 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
103 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_3.cpp | 130 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
131 tcp::socket socket = acceptor.accept(); in test_callback()
156 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
157 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_4.cpp | 146 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
147 tcp::socket socket = acceptor.accept(); in test_callback()
172 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
173 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_8.cpp | 157 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
158 tcp::socket socket = acceptor.accept(); in test_callback()
183 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
184 tcp::socket socket = acceptor.accept(); in test_future()
|
| /third_party/boost/libs/asio/example/cpp14/operations/ |
| D | composed_1.cpp | 58 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
59 tcp::socket socket = acceptor.accept(); in test_callback()
84 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
85 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_2.cpp | 76 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
77 tcp::socket socket = acceptor.accept(); in test_callback()
102 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
103 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_3.cpp | 130 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
131 tcp::socket socket = acceptor.accept(); in test_callback()
156 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
157 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_4.cpp | 146 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
147 tcp::socket socket = acceptor.accept(); in test_callback()
172 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
173 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_8.cpp | 157 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
158 tcp::socket socket = acceptor.accept(); in test_callback()
183 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
184 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_7.cpp | 164 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
165 tcp::socket socket = acceptor.accept(); in test_callback()
190 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
191 tcp::socket socket = acceptor.accept(); in test_future()
|
| /third_party/boost/libs/beast/example/websocket/server/coro/ |
| D | websocket_server_coro.cpp | 105 tcp::acceptor acceptor(ioc); in do_listen() local
106 acceptor.open(endpoint.protocol(), ec); in do_listen()
111 acceptor.set_option(net::socket_base::reuse_address(true), ec); in do_listen()
116 acceptor.bind(endpoint, ec); in do_listen()
121 acceptor.listen(net::socket_base::max_listen_connections, ec); in do_listen()
128 acceptor.async_accept(socket, yield[ec]); in do_listen()
133 acceptor.get_executor(), in do_listen()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/operations/ |
| D | composed_1.cpp | 58 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
59 tcp::socket socket = acceptor.accept(); in test_callback()
84 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
85 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_2.cpp | 76 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
77 tcp::socket socket = acceptor.accept(); in test_callback()
102 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
103 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_3.cpp | 136 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
137 tcp::socket socket = acceptor.accept(); in test_callback()
162 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
163 tcp::socket socket = acceptor.accept(); in test_future()
|
| /third_party/boost/libs/asio/example/cpp11/operations/ |
| D | composed_1.cpp | 58 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
59 tcp::socket socket = acceptor.accept(); in test_callback()
84 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
85 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_2.cpp | 76 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
77 tcp::socket socket = acceptor.accept(); in test_callback()
102 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
103 tcp::socket socket = acceptor.accept(); in test_future()
|
| D | composed_3.cpp | 136 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_callback() local
137 tcp::socket socket = acceptor.accept(); in test_callback()
162 tcp::acceptor acceptor(io_context, {tcp::v4(), 55555}); in test_future() local
163 tcp::socket socket = acceptor.accept(); in test_future()
|
| /third_party/boost/libs/beast/example/websocket/server/fast/ |
| D | websocket_server_fast.cpp | 122 tcp::acceptor acceptor{ioc, endpoint}; in do_sync_listen() local
127 acceptor.accept(socket, ec); in do_sync_listen()
245 tcp::acceptor acceptor_;
380 tcp::acceptor acceptor(ioc); in do_coro_listen() local
381 acceptor.open(endpoint.protocol(), ec); in do_coro_listen()
385 acceptor.set_option(net::socket_base::reuse_address(true), ec); in do_coro_listen()
389 acceptor.bind(endpoint, ec); in do_coro_listen()
393 acceptor.listen(net::socket_base::max_listen_connections, ec); in do_coro_listen()
401 acceptor.async_accept(socket, yield[ec]); in do_coro_listen()
409 acceptor.get_executor(), in do_coro_listen()
|
| /third_party/boost/libs/beast/example/websocket/server/coro-ssl/ |
| D | websocket_server_coro_ssl.cpp | 124 tcp::acceptor acceptor(ioc); in do_listen() local
125 acceptor.open(endpoint.protocol(), ec); in do_listen()
130 acceptor.set_option(net::socket_base::reuse_address(true), ec); in do_listen()
135 acceptor.bind(endpoint, ec); in do_listen()
140 acceptor.listen(net::socket_base::max_listen_connections, ec); in do_listen()
147 acceptor.async_accept(socket, yield[ec]); in do_listen()
152 acceptor.get_executor(), in do_listen()
|