Lines Matching refs:m_message_queue
81 m_message_queue.push_back(message);
94 pop_heap(m_message_queue.begin(), m_message_queue.end(),
96 m_message_queue.pop_back();
102 Message* msg_ptr = m_message_queue.front().get();
115 MsgPtr node = m_message_queue.front();
116 pop_heap(m_message_queue.begin(), m_message_queue.end(), greater<MsgPtr>());
121 m_message_queue.back() = node;
122 push_heap(m_message_queue.begin(), m_message_queue.end(),
131 return ((!m_message_queue.empty()) &&
132 (m_message_queue.front()->getLastEnqueueTime() <= current_time));