Home
last modified time | relevance | path

Searched refs:waiting_producers_ (Results 1 – 2 of 2) sorted by relevance

/third_party/boost/boost/fiber/
Dbuffered_channel.hpp44 wait_queue_type waiting_producers_{}; member in boost::fibers::buffered_channel
93 while ( ! waiting_producers_.empty() ) { in close()
94 context * producer_ctx = & waiting_producers_.front(); in close()
95 waiting_producers_.pop_front(); in close()
197 active_ctx->wait_link( waiting_producers_); in push()
236 active_ctx->wait_link( waiting_producers_); in push()
292 active_ctx->wait_link( waiting_producers_); in push_wait_until()
299 waiting_producers_.remove( * active_ctx); in push_wait_until()
340 active_ctx->wait_link( waiting_producers_); in push_wait_until()
347 waiting_producers_.remove( * active_ctx); in push_wait_until()
[all …]
Dunbuffered_channel.hpp64 wait_queue_type waiting_producers_{}; member in boost::fibers::unbuffered_channel
124 while ( ! waiting_producers_.empty() ) { in close()
125 context * producer_ctx = & waiting_producers_.front(); in close()
126 waiting_producers_.pop_front(); in close()
198 active_ctx->wait_link( waiting_producers_); in push()
248 active_ctx->wait_link( waiting_producers_); in push()
323 active_ctx->wait_link( waiting_producers_); in push_wait_until()
330 waiting_producers_.remove( * active_ctx); in push_wait_until()
389 active_ctx->wait_link( waiting_producers_); in push_wait_until()
396 waiting_producers_.remove( * active_ctx); in push_wait_until()
[all …]