/external/chromium_org/chrome_frame/ |
sync_msg_reply_dispatcher.cc | 18 message_queue_.push_back(context); 40 PendingSyncMessageQueue::iterator it = message_queue_.begin(); 41 while (it != message_queue_.end()) { 44 it = message_queue_.erase(it); 60 for (it = message_queue_.begin(); it != message_queue_.end(); ++it) { 63 message_queue_.erase(it);
|
sync_msg_reply_dispatcher.h | 114 PendingSyncMessageQueue message_queue_; member in class:SyncMessageReplyDispatcher
|
/external/chromium_org/content/child/ |
webmessageportchannel_impl.cc | 46 while (!message_queue_.empty()) { 48 message_queue_.front().ports; 52 message_queue_.pop(); 118 if (message_queue_.empty()) 121 *message = message_queue_.front().message; 123 message_queue_.front().ports; 130 message_queue_.pop(); 220 bool was_empty = message_queue_.empty(); 221 message_queue_.push(msg); 231 queued_messages.reserve(message_queue_.size()) [all...] |
resource_dispatcher_unittest.cc | 103 message_queue_.push_back(IPC::Message(*msg)); 111 while (!message_queue_.empty()) { 115 &message_queue_[0], &request_id, &request)); 137 dispatcher_->OnSetDataBuffer(message_queue_[0], request_id, dup_handle, 139 dispatcher_->OnReceivedData(message_queue_[0], request_id, 0, 143 message_queue_.erase(message_queue_.begin()); 148 &message_queue_[0], &request_ack)); 152 message_queue_.erase(message_queue_.begin()) 186 std::vector<IPC::Message> message_queue_; member in class:content::ResourceDispatcherTest [all...] |
webmessageportchannel_impl.h | 75 MessageQueue message_queue_; member in class:content::WebMessagePortChannelImpl
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
pingtask.cc | 17 message_queue_(message_queue), 72 message_queue_->PostDelayed(ping_timeout_millis_, this); 73 message_queue_->PostDelayed(ping_period_millis_, this);
|
pingtask.h | 62 talk_base::MessageQueue* message_queue_; member in class:buzz::PingTask
|
/external/chromium_org/ipc/ |
ipc_sync_channel.cc | 70 message_queue_.push_back(QueuedMessage(new Message(msg), context)); 106 it = message_queue_.begin(); 109 for (; it != message_queue_.end(); it++) { 115 it = message_queue_.erase(it); 134 SyncMessageQueue::iterator iter = message_queue_.begin(); 135 while (iter != message_queue_.end()) { 138 iter = message_queue_.erase(iter); 205 SyncMessageQueue message_queue_; member in class:IPC::SyncChannel::ReceivedSyncMsgQueue
|
/external/chromium_org/content/public/test/ |
browser_test_utils.cc | 486 message_queue_.push(dom_op_details->json); 494 message_queue_ = std::queue<std::string>(); 498 if (message_queue_.empty()) { 505 if (message_queue_.empty()) 508 *message = message_queue_.front(); 509 message_queue_.pop();
|
browser_test_utils.h | 220 std::queue<std::string> message_queue_; member in class:content::DOMMessageQueue
|
/external/chromium/third_party/libjingle/source/talk/base/ |
win32socketserver.h | 133 MessageQueue *message_queue_; member in class:talk_base::Win32SocketServer
|
win32socketserver.cc | 695 : message_queue_(message_queue), wnd_(this), posted_(false) { 724 message_queue_ = queue; 785 for (size_t max_messages_to_process = _max<size_t>(1, message_queue_->size()); 786 max_messages_to_process > 0 && message_queue_->Get(&msg, 0, false); 788 message_queue_->Dispatch(&msg); 792 int delay = message_queue_->GetDelay();
|
/external/chromium_org/third_party/libjingle/source/talk/base/ |
win32socketserver.cc | 728 : message_queue_(message_queue), 768 message_queue_ = queue; 838 for (size_t max_messages_to_process = _max<size_t>(1, message_queue_->size()); 839 max_messages_to_process > 0 && message_queue_->Get(&msg, 0, false); 841 message_queue_->Dispatch(&msg); 845 int delay = message_queue_->GetDelay();
|
win32socketserver.h | 142 MessageQueue *message_queue_; member in class:talk_base::Win32SocketServer
|