| /external/chromium_org/mojo/system/ |
| H A D | local_message_pipe_endpoint.h | 48 MessageInTransitQueue* message_queue() { return &message_queue_; } function in class:mojo::system::LocalMessagePipeEndpoint
|
| H A D | channel_endpoint.cc | 25 void ChannelEndpoint::TakeMessages(MessageInTransitQueue* message_queue) { argument
27 paused_message_queue_.Swap(message_queue);
|
| /external/chromium_org/content/renderer/gpu/ |
| H A D | queue_message_swap_promise.cc | 14 scoped_refptr<content::FrameSwapMessageQueue> message_queue,
17 message_queue_(message_queue),
12 QueueMessageSwapPromise( scoped_refptr<IPC::SyncMessageFilter> message_sender, scoped_refptr<content::FrameSwapMessageQueue> message_queue, int source_frame_number) argument
|
| /external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
| H A D | pingtask.cc | 13 rtc::MessageQueue* message_queue,
17 message_queue_(message_queue),
12 PingTask(buzz::XmppTaskParentInterface* parent, rtc::MessageQueue* message_queue, uint32 ping_period_millis, uint32 ping_timeout_millis) argument
|
| /external/chromium_org/chrome/browser/ui/ |
| H A D | browser_tabrestore_browsertest.cc | 22 void AwaitTabsReady(content::DOMMessageQueue* message_queue, int tabs) { argument
25 EXPECT_TRUE(message_queue->WaitForMessage(&message));
|
| /external/chromium_org/chrome/browser/ui/webui/signin/ |
| H A D | inline_login_ui_browsertest.cc | 147 content::DOMMessageQueue message_queue; local
163 ASSERT_TRUE(message_queue.WaitForMessage(&message));
|
| /external/chromium_org/mojo/public/cpp/bindings/tests/ |
| H A D | router_unittest.cc | 9 #include "mojo/public/cpp/bindings/lib/message_queue.h"
141 internal::MessageQueue message_queue; local
142 router0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue));
146 EXPECT_FALSE(message_queue.IsEmpty());
149 message_queue.Pop(&response);
165 internal::MessageQueue message_queue; local
166 router0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue));
171 EXPECT_FALSE(message_queue.IsEmpty());
174 message_queue.Pop(&response);
190 internal::MessageQueue message_queue; local
215 internal::MessageQueue message_queue; local
[all...] |
| /external/chromium_org/third_party/webrtc/base/ |
| H A D | messagequeue.cc | 53 void MessageQueueManager::Add(MessageQueue *message_queue) { argument
54 return Instance()->AddInternal(message_queue);
56 void MessageQueueManager::AddInternal(MessageQueue *message_queue) { argument
62 message_queues_.push_back(message_queue);
65 void MessageQueueManager::Remove(MessageQueue *message_queue) { argument
69 return Instance()->RemoveInternal(message_queue);
71 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) { argument
82 message_queue);
|
| H A D | win32socketserver.cc | 713 Win32SocketServer::Win32SocketServer(MessageQueue* message_queue) argument
714 : message_queue_(message_queue),
|
| /external/chromium_org/chrome/browser/sessions/ |
| H A D | session_restore_browsertest.cc | 244 content::DOMMessageQueue message_queue; local
248 EXPECT_TRUE(message_queue.WaitForMessage(&message));
|
| /external/chromium_org/content/browser/renderer_host/ |
| H A D | render_widget_host_view_browsertest.cc | 222 content::DOMMessageQueue message_queue; variable
226 if (!message_queue.WaitForMessage(&result)) {
|
| /external/chromium_org/content/browser/shared_worker/ |
| H A D | shared_worker_service_impl_unittest.cc | 110 ScopedVector<IPC::Message>* message_queue)
111 : MessagePortMessageFilter(callback), message_queue_(message_queue) {}
138 ScopedVector<IPC::Message>* message_queue)
143 message_queue_(message_queue) {}
109 MockMessagePortMessageFilter(const NextRoutingIDCallback& callback, ScopedVector<IPC::Message>* message_queue) argument
134 MockSharedWorkerMessageFilter(int render_process_id, ResourceContext* resource_context, const WorkerStoragePartition& partition, MessagePortMessageFilter* message_port_filter, ScopedVector<IPC::Message>* message_queue) argument
|
| /external/chromium_org/chrome/browser/chromeos/login/saml/ |
| H A D | saml_browsertest.cc | 359 content::DOMMessageQueue message_queue; // Start observe before SAML. local
363 ASSERT_TRUE(message_queue.WaitForMessage(&message));
450 content::DOMMessageQueue message_queue; // Observe before 'cancel'. local
458 ASSERT_TRUE(message_queue.WaitForMessage(&message));
761 content::DOMMessageQueue message_queue; local
763 ASSERT_TRUE(message_queue.WaitForMessage(&message));
|