| /third_party/boost/libs/asio/example/cpp03/timeouts/ |
| D | async_tcp_client.cpp | 88 : stopped_(false), in client()
114 stopped_ = true; in stop()
146 if (stopped_) in handle_connect()
200 if (stopped_) in handle_read()
227 if (stopped_) in start_write()
237 if (stopped_) in handle_write()
256 if (stopped_) in check_deadline()
279 bool stopped_; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/timeouts/ |
| D | async_tcp_client.cpp | 88 : stopped_(false), in client()
114 stopped_ = true; in stop()
146 if (stopped_) in handle_connect()
200 if (stopped_) in handle_read()
227 if (stopped_) in start_write()
237 if (stopped_) in handle_write()
256 if (stopped_) in check_deadline()
279 bool stopped_; member in client
|
| /third_party/boost/libs/asio/example/cpp11/timeouts/ |
| D | async_tcp_client.cpp | 115 stopped_ = true; in stop()
147 if (stopped_) in handle_connect()
200 if (stopped_) in handle_read()
227 if (stopped_) in start_write()
237 if (stopped_) in handle_write()
256 if (stopped_) in check_deadline()
279 bool stopped_ = false; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/timeouts/ |
| D | async_tcp_client.cpp | 115 stopped_ = true; in stop()
147 if (stopped_) in handle_connect()
200 if (stopped_) in handle_read()
227 if (stopped_) in start_write()
237 if (stopped_) in handle_write()
256 if (stopped_) in check_deadline()
279 bool stopped_ = false; member in client
|
| /third_party/nghttp2/src/ |
| D | asio_server_connection.h | 85 stopped_(false) {} in connection()
116 if (stopped_) { in handle_deadline()
217 if (stopped_) { in stop()
221 stopped_ = true; in stop()
244 bool stopped_; variable
|
| D | asio_client_session_impl.cc | 56 stopped_(false) {} in session_impl()
90 if (stopped_) { in handle_deadline()
115 if (stopped_ || ec == boost::asio::error::operation_aborted || in handle_ping()
159 if (stopped_) { in call_error_cb()
427 if (stopped_) { in cancel()
437 if (stopped_) { in resume()
485 if (stopped_) { in submit()
580 if (stopped_) { in shutdown()
621 if (stopped_) { in do_read()
665 if (stopped_) { in do_write()
[all …]
|
| D | asio_client_session_impl.h | 136 bool stopped_; variable
|
| /third_party/boost/libs/asio/example/cpp11/executors/ |
| D | priority_scheduler.cpp | 72 condition_.wait(lock, [&]{ return stopped_ || !queue_.empty(); }); in run()
73 if (stopped_) in run()
86 stopped_ = true; in stop()
130 bool stopped_ = false; member in priority_scheduler
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/executors/ |
| D | priority_scheduler.cpp | 72 condition_.wait(lock, [&]{ return stopped_ || !queue_.empty(); }); in run()
73 if (stopped_) in run()
86 stopped_ = true; in stop()
130 bool stopped_ = false; member in priority_scheduler
|
| /third_party/boost/libs/asio/example/cpp14/executors/ |
| D | priority_scheduler.cpp | 99 condition_.wait(lock, [&]{ return stopped_ || !queue_.empty(); }); in run()
100 if (stopped_) in run()
113 stopped_ = true; in stop()
157 bool stopped_ = false; member in priority_scheduler
|
| /third_party/boost/boost/asio/detail/ |
| D | win_iocp_io_context.hpp | 90 return ::InterlockedExchangeAdd(&stopped_, 0) != 0; in stopped()
96 ::InterlockedExchange(&stopped_, 0); in restart()
258 mutable long stopped_; member in boost::asio::detail::win_iocp_io_context
|
| D | scheduler.hpp | 209 bool stopped_; member in boost::asio::detail::scheduler
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | win_iocp_io_context.hpp | 90 return ::InterlockedExchangeAdd(&stopped_, 0) != 0; in stopped()
96 ::InterlockedExchange(&stopped_, 0); in restart()
258 mutable long stopped_; member in boost::asio::detail::win_iocp_io_context
|
| D | scheduler.hpp | 209 bool stopped_; member in boost::asio::detail::scheduler
|
| /third_party/mindspore/mindspore/ccsrc/cxx_api/model/model_converter_utils/ |
| D | multi_process.cc | 117 stopped_ = true; in ParentProcess()
138 stopped_ = true; in ChildProcess()
216 while (!stopped_) { in HeartbeatThreadFuncInner()
|
| D | multi_process.h | 53 bool stopped_ = false; variable
|
| /third_party/node/src/ |
| D | node_worker.cc | 93 return stopped_; in is_stopped()
280 stopped_ = true; in Run()
331 if (stopped_) return; in Run()
455 CHECK(stopped_); in ~Worker()
619 w->stopped_ = false; in StartThread()
669 w->stopped_ = true; in StartThread()
736 stopped_ = true; in Exit()
805 if (w->stopped_ || w->env_ == nullptr) in LoopIdleTime()
820 if (w->stopped_ || w->env_ == nullptr) in LoopStartTime()
|
| D | node_platform.cc | 550 outstanding_tasks_(0), stopped_(false), task_queue_() { } in TaskQueue()
574 while (task_queue_.empty() && !stopped_) { in BlockingPop()
577 if (stopped_) { in BlockingPop()
604 stopped_ = true; in Stop()
|
| D | node_worker.h | 117 bool stopped_ = true; variable
|
| D | node_platform.h | 41 bool stopped_; variable
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | scheduler.ipp | 120 stopped_(false),
313 return stopped_;
319 stopped_ = false;
446 while (!stopped_)
506 if (stopped_)
577 if (stopped_)
631 stopped_ = true;
|
| D | win_iocp_io_context.ipp | 87 stopped_(0),
276 if (::InterlockedExchange(&stopped_, 1) == 0)
506 // The stopped_ flag is always checked to ensure that any leftover
508 if (::InterlockedExchangeAdd(&stopped_, 0) != 0)
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | scheduler.ipp | 120 stopped_(false),
313 return stopped_;
319 stopped_ = false;
446 while (!stopped_)
506 if (stopped_)
577 if (stopped_)
631 stopped_ = true;
|
| D | win_iocp_io_context.ipp | 87 stopped_(0),
276 if (::InterlockedExchange(&stopped_, 1) == 0)
506 // The stopped_ flag is always checked to ensure that any leftover
508 if (::InterlockedExchangeAdd(&stopped_, 0) != 0)
|