| /third_party/boost/libs/asio/include/boost/asio/impl/ |
| D | io_context.hpp | 224 io_context* old_io_context = io_context_; in operator =()
225 io_context_ = other.io_context_; in operator =()
230 if (io_context_) in operator =()
231 io_context_->impl_.work_started(); in operator =()
247 io_context* old_io_context = io_context_; in operator =()
248 io_context_ = other.io_context_; in operator =()
253 other.io_context_ = 0; in operator =()
266 return io_context_->impl_.can_dispatch(); in running_in_this_thread()
278 if ((bits_ & blocking_never) == 0 && io_context_->impl_.can_dispatch()) in execute()
297 io_context_->impl_.capture_current_exception(); in execute()
[all …]
|
| /third_party/boost/boost/asio/impl/ |
| D | io_context.hpp | 224 io_context* old_io_context = io_context_; in operator =()
225 io_context_ = other.io_context_; in operator =()
230 if (io_context_) in operator =()
231 io_context_->impl_.work_started(); in operator =()
247 io_context* old_io_context = io_context_; in operator =()
248 io_context_ = other.io_context_; in operator =()
253 other.io_context_ = 0; in operator =()
266 return io_context_->impl_.can_dispatch(); in running_in_this_thread()
278 if ((bits_ & blocking_never) == 0 && io_context_->impl_.can_dispatch()) in execute()
297 io_context_->impl_.capture_current_exception(); in execute()
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/ |
| D | io_context.hpp | 678 : io_context_(other.io_context_), in basic_executor_type()
683 if (io_context_) in basic_executor_type()
684 io_context_->impl_.work_started(); in basic_executor_type()
690 : io_context_(other.io_context_), in basic_executor_type()
695 other.io_context_ = 0; in basic_executor_type()
703 if (io_context_) in ~basic_executor_type()
704 io_context_->impl_.work_finished(); in ~basic_executor_type()
736 return basic_executor_type(io_context_, in require()
753 return basic_executor_type(io_context_, in require()
770 return basic_executor_type(io_context_, in require()
[all …]
|
| /third_party/boost/boost/asio/ |
| D | io_context.hpp | 678 : io_context_(other.io_context_), in basic_executor_type()
683 if (io_context_) in basic_executor_type()
684 io_context_->impl_.work_started(); in basic_executor_type()
690 : io_context_(other.io_context_), in basic_executor_type()
695 other.io_context_ = 0; in basic_executor_type()
703 if (io_context_) in ~basic_executor_type()
704 io_context_->impl_.work_finished(); in ~basic_executor_type()
736 return basic_executor_type(io_context_, in require()
753 return basic_executor_type(io_context_, in require()
770 return basic_executor_type(io_context_, in require()
[all …]
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server/ |
| D | server.cpp | 20 : io_context_(), in server()
21 signals_(io_context_), in server()
22 acceptor_(io_context_), in server()
38 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
55 io_context_.run(); in run()
60 new_connection_.reset(new connection(io_context_, in start_accept()
|
| /third_party/boost/libs/asio/example/cpp03/http/server/ |
| D | server.cpp | 20 : io_context_(), in server()
21 signals_(io_context_), in server()
22 acceptor_(io_context_), in server()
38 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
55 io_context_.run(); in run()
60 new_connection_.reset(new connection(io_context_, in start_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/timeouts/ |
| D | blocking_tcp_client.cpp | 43 auto endpoints = tcp::resolver(io_context_).resolve(host, service); in connect()
124 io_context_.restart(); in run()
130 io_context_.run_for(timeout); in run()
135 if (!io_context_.stopped()) in run()
141 io_context_.run(); in run()
145 boost::asio::io_context io_context_; member in client
146 tcp::socket socket_{io_context_};
|
| D | blocking_udp_client.cpp | 51 : socket_(io_context_, listen_endpoint) in client()
76 io_context_.restart(); in run()
82 io_context_.run_for(timeout); in run()
87 if (!io_context_.stopped()) in run()
93 io_context_.run(); in run()
106 boost::asio::io_context io_context_; member in client
|
| /third_party/boost/libs/asio/example/cpp11/timeouts/ |
| D | blocking_tcp_client.cpp | 43 auto endpoints = tcp::resolver(io_context_).resolve(host, service); in connect()
124 io_context_.restart(); in run()
130 io_context_.run_for(timeout); in run()
135 if (!io_context_.stopped()) in run()
141 io_context_.run(); in run()
145 boost::asio::io_context io_context_; member in client
146 tcp::socket socket_{io_context_};
|
| D | blocking_udp_client.cpp | 51 : socket_(io_context_, listen_endpoint) in client()
76 io_context_.restart(); in run()
82 io_context_.run_for(timeout); in run()
87 if (!io_context_.stopped()) in run()
93 io_context_.run(); in run()
106 boost::asio::io_context io_context_; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/timeouts/ |
| D | blocking_udp_client.cpp | 49 : socket_(io_context_, listen_endpoint) in client()
75 io_context_.restart(); in run()
81 io_context_.run_for(timeout); in run()
86 if (!io_context_.stopped()) in run()
92 io_context_.run(); in run()
105 boost::asio::io_context io_context_; member in client
|
| D | blocking_tcp_client.cpp | 46 : socket_(io_context_) in client()
55 tcp::resolver(io_context_).resolve(host, service); in connect()
121 io_context_.restart(); in run()
127 io_context_.run_for(timeout); in run()
132 if (!io_context_.stopped()) in run()
138 io_context_.run(); in run()
142 boost::asio::io_context io_context_; member in client
|
| /third_party/boost/libs/asio/example/cpp03/timeouts/ |
| D | blocking_udp_client.cpp | 49 : socket_(io_context_, listen_endpoint) in client()
75 io_context_.restart(); in run()
81 io_context_.run_for(timeout); in run()
86 if (!io_context_.stopped()) in run()
92 io_context_.run(); in run()
105 boost::asio::io_context io_context_; member in client
|
| D | blocking_tcp_client.cpp | 46 : socket_(io_context_) in client()
55 tcp::resolver(io_context_).resolve(host, service); in connect()
121 io_context_.restart(); in run()
127 io_context_.run_for(timeout); in run()
132 if (!io_context_.stopped()) in run()
138 io_context_.run(); in run()
142 boost::asio::io_context io_context_; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server3/ |
| D | server.cpp | 23 signals_(io_context_), in server()
24 acceptor_(io_context_), in server()
39 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
57 boost::bind(&boost::asio::io_context::run, &io_context_))); in run()
68 new_connection_.reset(new connection(io_context_, request_handler_)); in start_accept()
86 io_context_.stop(); in handle_stop()
|
| /third_party/boost/libs/asio/example/cpp03/http/server3/ |
| D | server.cpp | 23 signals_(io_context_), in server()
24 acceptor_(io_context_), in server()
39 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
57 boost::bind(&boost::asio::io_context::run, &io_context_))); in run()
68 new_connection_.reset(new connection(io_context_, request_handler_)); in start_accept()
86 io_context_.stop(); in handle_stop()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/http/server/ |
| D | server.cpp | 20 : io_context_(1), in server()
21 signals_(io_context_), in server()
22 acceptor_(io_context_), in server()
38 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
55 io_context_.run(); in run()
|
| /third_party/boost/libs/asio/example/cpp11/http/server/ |
| D | server.cpp | 20 : io_context_(1), in server()
21 signals_(io_context_), in server()
22 acceptor_(io_context_), in server()
38 boost::asio::ip::tcp::resolver resolver(io_context_); in server()
55 io_context_.run(); in run()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 27 : io_context_(io_context), in server()
70 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in accept()
97 io_context_.notify_fork(boost::asio::io_context::fork_parent); in accept()
134 boost::asio::io_context& io_context_; member in server
|
| /third_party/boost/libs/asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 27 : io_context_(io_context), in server()
70 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in accept()
97 io_context_.notify_fork(boost::asio::io_context::fork_parent); in accept()
134 boost::asio::io_context& io_context_; member in server
|
| /third_party/boost/libs/asio/example/cpp03/fork/ |
| D | process_per_connection.cpp | 29 : io_context_(io_context), in server()
71 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in handle_accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in handle_accept()
95 io_context_.notify_fork(boost::asio::io_context::fork_parent); in handle_accept()
133 boost::asio::io_context& io_context_; member in server
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/fork/ |
| D | process_per_connection.cpp | 29 : io_context_(io_context), in server()
71 io_context_.notify_fork(boost::asio::io_context::fork_prepare); in handle_accept()
78 io_context_.notify_fork(boost::asio::io_context::fork_child); in handle_accept()
95 io_context_.notify_fork(boost::asio::io_context::fork_parent); in handle_accept()
133 boost::asio::io_context& io_context_; member in server
|
| /third_party/boost/libs/asio/test/ |
| D | is_write_buffered.cpp | 37 : io_context_(io_context) in test_stream()
43 return io_context_; in io_context()
68 boost::asio::post(io_context_, in async_write()
89 boost::asio::post(io_context_, in async_read()
94 io_context_type& io_context_; member in test_stream
|
| D | is_read_buffered.cpp | 37 : io_context_(io_context) in test_stream()
43 return io_context_; in io_context()
68 boost::asio::post(io_context_, in async_write()
89 boost::asio::post(io_context_, in async_read()
94 io_context_type& io_context_; member in test_stream
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/buffers/ |
| D | reference_counted.cpp | 80 : io_context_(io_context), in server()
83 session_ptr new_session(new session(io_context_)); in server()
97 new_session.reset(new session(io_context_)); in handle_accept()
104 boost::asio::io_context& io_context_; member in server
|