| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| D | router_unittest.cc | 53 MessageQueue message_queue; in TEST_F() local
56 &request, new MessageAccumulator(&message_queue, run_loop.QuitClosure())); in TEST_F()
60 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
63 message_queue.Pop(&response); in TEST_F()
75 new MessageAccumulator(&message_queue, run_loop2.QuitClosure())); in TEST_F()
79 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
81 message_queue.Pop(&response); in TEST_F()
99 MessageQueue message_queue; in TEST_F() local
100 router0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue)); in TEST_F()
105 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
[all …]
|
| D | multiplex_router_unittest.cc | 78 MessageQueue message_queue; in TEST_F() local
82 new MessageAccumulator(&message_queue, run_loop.QuitClosure())); in TEST_F()
86 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
89 message_queue.Pop(&response); in TEST_F()
101 new MessageAccumulator(&message_queue, run_loop2.QuitClosure())); in TEST_F()
105 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
107 message_queue.Pop(&response); in TEST_F()
125 MessageQueue message_queue; in TEST_F() local
126 client0.AcceptWithResponder(&request, new MessageAccumulator(&message_queue)); in TEST_F()
131 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
[all …]
|
| D | BUILD.gn | 27 "message_queue.cc",
28 "message_queue.h",
|
| /external/webrtc/webrtc/base/ |
| D | messagequeue.cc | 55 void MessageQueueManager::Add(MessageQueue *message_queue) { in Add() argument
56 return Instance()->AddInternal(message_queue); in Add()
58 void MessageQueueManager::AddInternal(MessageQueue *message_queue) { in AddInternal() argument
66 message_queues_.push_back(message_queue); in AddInternal()
69 void MessageQueueManager::Remove(MessageQueue *message_queue) { in Remove() argument
73 return Instance()->RemoveInternal(message_queue); in Remove()
75 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) { in RemoveInternal() argument
88 message_queue); in RemoveInternal()
|
| D | messagequeue.h | 40 static void Add(MessageQueue *message_queue);
41 static void Remove(MessageQueue *message_queue);
56 void AddInternal(MessageQueue *message_queue);
57 void RemoveInternal(MessageQueue *message_queue);
|
| D | win32socketserver.h | 93 explicit Win32SocketServer(MessageQueue* message_queue);
|
| D | win32socketserver.cc | 716 Win32SocketServer::Win32SocketServer(MessageQueue* message_queue) in Win32SocketServer() argument
717 : message_queue_(message_queue), in Win32SocketServer()
|
| /external/libmojo/mojo/edk/system/ports/ |
| D | BUILD.gn | 13 "message_queue.cc",
14 "message_queue.h",
|
| D | node.cc | 32 uint64_t next_sequence_num = port->message_queue.next_sequence_num(); in CanAcceptMoreMessages()
230 port->message_queue.GetReferencedPorts(&referenced_port_names); in ClosePort()
258 port_status->has_messages = port->message_queue.HasNextMessage(); in GetStatus()
289 port->message_queue.GetNextMessageIf(std::move(selector), message); in GetMessageIf()
304 new_port->message_queue.set_signalable(true); in GetMessageIf()
461 port->message_queue.AcceptMessage(std::move(message), &has_next_message); in OnUserMessage()
978 port->message_queue.next_sequence_num(); in WillSendPort()
1007 port->message_queue.set_signalable(false); in AcceptPort()
1188 port->message_queue.GetNextMessageIf(nullptr, &message); in ForwardMessages_Locked()
1318 port->message_queue.next_sequence_num() - 1; in DestroyAllPortsWithPeer()
[all …]
|
| D | port.cc | 16 message_queue(next_sequence_num_to_receive), in Port()
|
| D | port.h | 39 MessageQueue message_queue; variable
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | pingtask.cc | 20 rtc::MessageQueue* message_queue, in PingTask() argument
24 message_queue_(message_queue), in PingTask()
|
| D | pingtask.h | 31 rtc::MessageQueue* message_queue,
|
| /external/libmojo/mojo/edk/system/ |
| D | node_controller.cc | 1005 auto& message_queue = entry.second; in OnAcceptBrokerClient() local
1006 while (!message_queue.empty()) { in OnAcceptBrokerClient()
1007 broker->RelayPortsMessage(destination, std::move(message_queue.front())); in OnAcceptBrokerClient()
1008 message_queue.pop(); in OnAcceptBrokerClient()
|
| /external/libmojo/mojo/ |
| D | mojo_edk_tests.gyp | 64 'public/cpp/bindings/tests/message_queue.cc',
65 'public/cpp/bindings/tests/message_queue.h',
|
| /external/libmojo/ |
| D | Android.mk | 110 mojo/edk/system/ports/message_queue.cc \
|