Searched refs:_msg_queue (Results 1 – 4 of 4) sorted by relevance
77 _msg_queue.clear(); in start()96 _msg_queue.push(0); in stop()98 _msg_queue.clear(); in stop()377 auto v = _msg_queue.front(); in raw_buffer_proc()382 _msg_queue.pop(); in raw_buffer_proc()406 _msg_queue.push(1); in send_sync_buf()
124 SafeQueue<int> _msg_queue; variable
340 _msg_queue.resume_pop(); in start()341 _msg_queue.clear(); in start()351 _msg_queue.pause_pop(); in stop()722 if (_msg_queue.pop(-1).ptr()) in raw_buffer_proc()785 _msg_queue.push(ec); in _send_sync_buf()
163 SafeList<EmptyClass> _msg_queue; variable