Home
last modified time | relevance | path

Searched refs:has_been_closed (Results 1 – 4 of 4) sorted by relevance

/third_party/boost/boost/thread/concurrent_queues/
Dsync_deque.hpp152 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in wait_pull_front() local
153 if (has_been_closed) return queue_op_status::closed; in wait_pull_front()
187 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull_front() local
188 if (has_been_closed) super::throw_if_closed(lk); in pull_front()
197 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull_front() local
198 if (has_been_closed) super::throw_if_closed(lk); in pull_front()
Dsync_queue.hpp152 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in wait_pull() local
153 if (has_been_closed) return queue_op_status::closed; in wait_pull()
187 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull() local
188 if (has_been_closed) super::throw_if_closed(lk); in pull()
197 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull() local
198 if (has_been_closed) super::throw_if_closed(lk); in pull()
Dsync_priority_queue.hpp252 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull() local
253 if (has_been_closed) super::throw_if_closed(lk); in pull()
273 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in pull() local
274 if (has_been_closed) super::throw_if_closed(lk); in pull()
338 const bool has_been_closed = super::wait_until_not_empty_or_closed(lk); in wait_pull() local
339 if (has_been_closed) return queue_op_status::closed; in wait_pull()
Dsync_timed_queue.hpp344 const bool has_been_closed = wait_to_pull(lk); in pull() local
345 if (has_been_closed) super::throw_if_closed(lk); in pull()
374 const bool has_been_closed = wait_to_pull(lk); in pull() local
375 if (has_been_closed) super::throw_if_closed(lk); in pull()
440 const bool has_been_closed = wait_to_pull(lk); in wait_pull() local
441 if (has_been_closed) return queue_op_status::closed; in wait_pull()