Searched refs:delayedQueue_ (Results 1 – 4 of 4) sorted by relevance
39 if (delayedQueue_.empty()) { in HaveDelayedMessageToProcess()42 auto message = *delayedQueue_.begin(); in HaveDelayedMessageToProcess()56 if (!delayedQueue_.empty()) { in WaitForMessage()57 auto message = *delayedQueue_.begin(); in WaitForMessage()79 auto top = delayedQueue_.begin(); in ProcessOneMessageInternal()81 delayedQueue_.erase(top); in ProcessOneMessageInternal()135 delayedQueue_.emplace(castTime, message, param); in PostMessage()149 for (auto pos = std::begin(delayedQueue_); pos != std::end(delayedQueue_);) { in RemoveMessages()151 pos = delayedQueue_.erase(pos); in RemoveMessages()
77 std::set<delayed_queue_element_t, Comp> delayedQueue_; variable
80 delayedQueue_; variable
113 delayedQueue_.Put(wrapper); in SetCacheDelayed()