| /third_party/boost/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /third_party/boost/libs/asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/http/server/ |
| D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept( in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /third_party/boost/libs/asio/example/cpp11/http/server/ |
| D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept( in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /third_party/boost/libs/asio/example/cpp03/http/server/ |
| D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
62 acceptor_.async_accept(new_connection_->socket(), in start_accept()
71 if (!acceptor_.is_open()) in handle_accept()
89 acceptor_.close(); in handle_stop()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server/ |
| D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
62 acceptor_.async_accept(new_connection_->socket(), in start_accept()
71 if (!acceptor_.is_open()) in handle_accept()
89 acceptor_.close(); in handle_stop()
|
| /third_party/boost/libs/beast/example/websocket/server/chat-multi/ |
| D | listener.cpp | 20 , acceptor_(ioc) in listener()
26 acceptor_.open(endpoint.protocol(), ec); in listener()
34 acceptor_.set_option(net::socket_base::reuse_address(true), ec); in listener()
42 acceptor_.bind(endpoint, ec); in listener()
50 acceptor_.listen( in listener()
64 acceptor_.async_accept( in run()
96 acceptor_.async_accept( in on_accept()
|
| /third_party/boost/libs/asio/example/cpp03/http/server2/ |
| D | server.cpp | 21 acceptor_(io_context_pool_.get_io_context()), in server()
36 boost::asio::ip::tcp::resolver resolver(acceptor_.get_executor()); in server()
39 acceptor_.open(endpoint.protocol()); in server()
40 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
41 acceptor_.bind(endpoint); in server()
42 acceptor_.listen(); in server()
56 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server2/ |
| D | server.cpp | 21 acceptor_(io_context_pool_.get_io_context()), in server()
36 boost::asio::ip::tcp::resolver resolver(acceptor_.get_executor()); in server()
39 acceptor_.open(endpoint.protocol()); in server()
40 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
41 acceptor_.bind(endpoint); in server()
42 acceptor_.listen(); in server()
56 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server3/ |
| D | server.cpp | 24 acceptor_(io_context_), in server()
42 acceptor_.open(endpoint.protocol()); in server()
43 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
44 acceptor_.bind(endpoint); in server()
45 acceptor_.listen(); in server()
69 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|
| /third_party/boost/libs/asio/example/cpp03/http/server3/ |
| D | server.cpp | 24 acceptor_(io_context_), in server()
42 acceptor_.open(endpoint.protocol()); in server()
43 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
44 acceptor_.bind(endpoint); in server()
45 acceptor_.listen(); in server()
69 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/serialization/ |
| D | server.cpp | 29 : acceptor_(io_context, in server()
58 connection_ptr new_conn(new connection(acceptor_.get_executor())); in server()
59 acceptor_.async_accept(new_conn->socket(), in server()
78 connection_ptr new_conn(new connection(acceptor_.get_executor())); in handle_accept()
79 acceptor_.async_accept(new_conn->socket(), in handle_accept()
93 boost::asio::ip::tcp::acceptor acceptor_; member in s11n_example::server
|
| /third_party/boost/libs/asio/example/cpp03/serialization/ |
| D | server.cpp | 29 : acceptor_(io_context, in server()
58 connection_ptr new_conn(new connection(acceptor_.get_executor())); in server()
59 acceptor_.async_accept(new_conn->socket(), in server()
78 connection_ptr new_conn(new connection(acceptor_.get_executor())); in handle_accept()
79 acceptor_.async_accept(new_conn->socket(), in handle_accept()
93 boost::asio::ip::tcp::acceptor acceptor_; member in s11n_example::server
|
| /third_party/boost/libs/beast/example/websocket/server/async/ |
| D | websocket_server_async.cpp | 164 tcp::acceptor acceptor_; member in listener
171 , acceptor_(ioc) in listener()
176 acceptor_.open(endpoint.protocol(), ec); in listener()
184 acceptor_.set_option(net::socket_base::reuse_address(true), ec); in listener()
192 acceptor_.bind(endpoint, ec); in listener()
200 acceptor_.listen( in listener()
221 acceptor_.async_accept( in do_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/porthopper/ |
| D | server.cpp | 33 : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
39 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in server()
40 acceptor_.async_accept(*new_socket, in server()
62 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in handle_accept()
63 acceptor_.async_accept(*new_socket, in handle_accept()
76 new boost::asio::steady_timer(acceptor_.get_executor())); in handle_control_request()
149 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/libs/beast/example/websocket/server/stackless/ |
| D | websocket_server_stackless.cpp | 157 tcp::acceptor acceptor_; member in listener
165 , acceptor_(net::make_strand(ioc)) in listener()
171 acceptor_.open(endpoint.protocol(), ec); in listener()
179 acceptor_.set_option(net::socket_base::reuse_address(true), ec); in listener()
187 acceptor_.bind(endpoint, ec); in listener()
195 acceptor_.listen( in listener()
222 yield acceptor_.async_accept(
|
| /third_party/boost/libs/asio/example/cpp03/porthopper/ |
| D | server.cpp | 33 : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
39 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in server()
40 acceptor_.async_accept(*new_socket, in server()
62 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in handle_accept()
63 acceptor_.async_accept(*new_socket, in handle_accept()
76 new boost::asio::steady_timer(acceptor_.get_executor())); in handle_control_request()
149 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 29 acceptor_(io_context, {tcp::v4(), port}), in server()
45 if (acceptor_.is_open()) in wait_for_signal()
59 acceptor_.async_accept( in accept()
82 acceptor_.close(); in accept()
136 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/libs/asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 29 acceptor_(io_context, {tcp::v4(), port}), in server()
45 if (acceptor_.is_open()) in wait_for_signal()
59 acceptor_.async_accept( in accept()
82 acceptor_.close(); in accept()
136 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/libs/beast/example/websocket/server/stackless-ssl/ |
| D | websocket_server_stackless_ssl.cpp | 181 tcp::acceptor acceptor_; member in listener
191 , acceptor_(ioc) in listener()
197 acceptor_.open(endpoint.protocol(), ec); in listener()
205 acceptor_.set_option(net::socket_base::reuse_address(true), ec); in listener()
213 acceptor_.bind(endpoint, ec); in listener()
221 acceptor_.listen( in listener()
248 yield acceptor_.async_accept(
|
| /third_party/boost/libs/beast/example/websocket/server/async-ssl/ |
| D | websocket_server_async_ssl.cpp | 192 tcp::acceptor acceptor_; member in listener
201 , acceptor_(net::make_strand(ioc)) in listener()
206 acceptor_.open(endpoint.protocol(), ec); in listener()
214 acceptor_.set_option(net::socket_base::reuse_address(true), ec); in listener()
222 acceptor_.bind(endpoint, ec); in listener()
230 acceptor_.listen( in listener()
251 acceptor_.async_accept( in do_accept()
|
| /third_party/boost/libs/asio/example/cpp03/fork/ |
| D | process_per_connection.cpp | 31 acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
48 if (acceptor_.is_open()) in handle_signal_wait()
60 acceptor_.async_accept(socket_, in start_accept()
82 acceptor_.close(); in handle_accept()
135 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/fork/ |
| D | process_per_connection.cpp | 31 acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), in server()
48 if (acceptor_.is_open()) in handle_signal_wait()
60 acceptor_.async_accept(socket_, in start_accept()
82 acceptor_.close(); in handle_accept()
135 tcp::acceptor acceptor_; member in server
|
| /third_party/boost/libs/asio/test/latency/ |
| D | tcp_server.cpp | 29 acceptor_(acceptor), in tcp_server()
30 socket_(acceptor_.get_executor()), in tcp_server()
39 yield acceptor_.async_accept(socket_, ref(this)); in operator ()()
76 tcp::acceptor& acceptor_; member in tcp_server
|
| /third_party/boost/libs/asio/example/cpp03/buffers/ |
| D | reference_counted.cpp | 81 acceptor_(io_context, tcp::endpoint(tcp::v4(), port)) in server()
84 acceptor_.async_accept(new_session->socket(), in server()
98 acceptor_.async_accept(new_session->socket(), in handle_accept()
105 tcp::acceptor acceptor_; member in server
|