| /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/mojo/system/ |
| local_message_pipe_endpoint.cc | 52 message_queue_.clear();
86 bool was_empty = message_queue_.empty();
87 message_queue_.push_back(MessageQueueEntry());
88 message_queue_.back().message = message;
98 message_queue_.back().dispatchers.swap(*dispatchers);
122 if (message_queue_.empty()) {
130 const MessageInTransit* queued_message = message_queue_.front().message;
139 &message_queue_.front().dispatchers;
154 message_queue_.pop_front();
157 if (message_queue_.empty())
[all...] |
| local_message_pipe_endpoint.h | 74 std::deque<MessageQueueEntry> message_queue_; member in class:mojo::system::LocalMessagePipeEndpoint
|
| /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));
142 message_queue_.erase(message_queue_.begin());
147 &message_queue_[0], &request_ack));
151 message_queue_.erase(message_queue_.begin());
186 std::vector<IPC::Message> message_queue_; member in class:content::ResourceDispatcherTest
|
| 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 | 616 message_queue_.push(dom_op_details->json);
624 message_queue_ = std::queue<std::string>();
628 if (message_queue_.empty()) {
635 if (message_queue_.empty())
638 *message = message_queue_.front();
639 message_queue_.pop();
|
| browser_test_utils.h | 268 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 | 731 : message_queue_(message_queue),
771 message_queue_ = queue;
841 for (size_t max_messages_to_process = _max<size_t>(1, message_queue_->size());
842 max_messages_to_process > 0 && message_queue_->Get(&msg, 0, false);
844 message_queue_->Dispatch(&msg);
848 int delay = message_queue_->GetDelay();
|
| win32socketserver.h | 142 MessageQueue *message_queue_; member in class:talk_base::Win32SocketServer
|
