Searched refs:message_queue_ (Results 1 – 4 of 4) sorted by relevance
34 void SetMessageQueue(rtc::Thread* queue) override { message_queue_ = queue; } in SetMessageQueue()51 message_queue_->Quit(); in Wait()58 rtc::Thread* message_queue_; member in CustomSocketServer
168 message_queue_.push_back(QueuedMessage(new Message(msg), context)); in QueueMessage()209 it = message_queue_.begin(); in DispatchMessages()212 for (; it != message_queue_.end(); it++) { in DispatchMessages()220 it = message_queue_.erase(it); in DispatchMessages()239 SyncMessageQueue::iterator iter = message_queue_.begin(); in RemoveContext()240 while (iter != message_queue_.end()) { in RemoveContext()243 iter = message_queue_.erase(iter); in RemoveContext()320 SyncMessageQueue message_queue_; member in IPC::SyncChannel::ReceivedSyncMsgQueue
702 message_queue_ = queue; in SetMessageQueue()773 std::max<size_t>(1, message_queue_->size()); in Pump()774 max_messages_to_process > 0 && message_queue_->Get(&msg, 0, false); in Pump()776 message_queue_->Dispatch(&msg); in Pump()780 int delay = message_queue_->GetDelay(); in Pump()
124 Thread* message_queue_; variable