Searched refs:drain_queue (Results 1 – 3 of 3) sorted by relevance
85 mutable queue_type drain_queue; member108 swap(drain_expired, drain_queue); in finish()122 if (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty()) { in ensure_processing()132 if (drain_queue.empty() || !destination.is_subscribed()) { in ensure_processing()135 … (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty())) { in ensure_processing()139 if (drain_queue.empty()) { in ensure_processing()144 swap(fill_queue, drain_queue); in ensure_processing()147 auto notification = std::move(drain_queue.front()); in ensure_processing()148 drain_queue.pop_front(); in ensure_processing()
58 auto drain_queue = [keepAlive, this](const rxsc::schedulable& self){ in ensure_processing() local85 [&](){return coordinator.act(drain_queue);}, in ensure_processing()
337 #define drain_queue() \ macro512 drain_queue(); in perf_test_thread()