Home
last modified time | relevance | path

Searched refs:message_queue_ (Results 1 – 5 of 5) sorted by relevance

/external/webrtc/webrtc/libjingle/xmpp/
Dpingtask.cc24 message_queue_(message_queue), in PingTask()
79 message_queue_->PostDelayed(ping_timeout_millis_, this); in ProcessStart()
80 message_queue_->PostDelayed(ping_period_millis_, this); in ProcessStart()
Dpingtask.h46 rtc::MessageQueue* message_queue_; variable
/external/libchrome/ipc/
Dipc_sync_channel.cc168 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
/external/webrtc/webrtc/base/
Dwin32socketserver.cc717 : message_queue_(message_queue), in Win32SocketServer()
757 message_queue_ = queue; in SetMessageQueue()
828 std::max<size_t>(1, message_queue_->size()); in Pump()
829 max_messages_to_process > 0 && message_queue_->Get(&msg, 0, false); in Pump()
831 message_queue_->Dispatch(&msg); in Pump()
835 int delay = message_queue_->GetDelay(); in Pump()
Dwin32socketserver.h125 MessageQueue *message_queue_; variable