| /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
|
