Lines Matching defs:MessageQueue
34 #include "talk/base/messagequeue.h"
61 void MessageQueueManager::Add(MessageQueue *message_queue) {
70 void MessageQueueManager::Remove(MessageQueue *message_queue) {
72 // If this is the last MessageQueue, destroy the manager as well so that
79 std::vector<MessageQueue *>::iterator iter;
96 std::vector<MessageQueue *>::iterator iter;
102 // MessageQueue
104 MessageQueue::MessageQueue(SocketServer* ss)
108 // Currently, MessageQueue holds a socket server, and is the base class for
110 // server, and provide it to the MessageQueue, since the Thread controls
119 MessageQueue::~MessageQueue() {
133 void MessageQueue::set_socketserver(SocketServer* ss) {
138 void MessageQueue::Quit() {
143 bool MessageQueue::IsQuitting() {
147 void MessageQueue::Restart() {
151 bool MessageQueue::Peek(Message *pmsg, int cmsWait) {
163 bool MessageQueue::Get(Message *pmsg, int cmsWait, bool process_io) {
262 void MessageQueue::ReceiveSends() {
265 void MessageQueue::Post(MessageHandler *phandler, uint32 id,
287 void MessageQueue::DoDelayPost(int cmsDelay, uint32 tstamp,
311 int MessageQueue::GetDelay() {
327 void MessageQueue::Clear(MessageHandler *phandler, uint32 id,
376 void MessageQueue::Dispatch(Message *pmsg) {
380 void MessageQueue::EnsureActive() {
