| /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/tensorflow/tensorflow/contrib/mpi_collectives/kernels/ |
| D | mpi_ops.cc | 210 std::queue<MPIRequest> message_queue; member
641 std::queue<MPIRequest> message_queue; in BackgroundThreadLoop() local
644 while (!mpi_global.message_queue.empty()) { in BackgroundThreadLoop()
645 MPIRequest message = mpi_global.message_queue.front(); in BackgroundThreadLoop()
646 mpi_global.message_queue.pop(); in BackgroundThreadLoop()
647 message_queue.push(message); in BackgroundThreadLoop()
655 while (!message_queue.empty()) { in BackgroundThreadLoop()
657 MPIRequest message = message_queue.front(); in BackgroundThreadLoop()
658 message_queue.pop(); in BackgroundThreadLoop()
850 mpi_global.message_queue.push(message); in EnqueueTensorCollective()
|
| /external/libmojo/mojo/edk/system/ports/ |
| D | BUILD.gn | 14 "message_queue.cc",
15 "message_queue.h",
|
| D | node.cc | 33 uint64_t next_sequence_num = port->message_queue.next_sequence_num(); in CanAcceptMoreMessages()
232 port->message_queue.GetReferencedPorts(&referenced_port_names); in ClosePort()
260 port_status->has_messages = port->message_queue.HasNextMessage(); in GetStatus()
287 port->message_queue.GetNextMessage(message, filter); in GetMessage()
302 new_port->message_queue.set_signalable(true); in GetMessage()
459 port->message_queue.AcceptMessage(std::move(message), &has_next_message); in OnUserMessage()
969 port->message_queue.next_sequence_num(); in WillSendPort()
998 port->message_queue.set_signalable(false); in AcceptPort()
1179 port->message_queue.GetNextMessage(&message, nullptr); in ForwardMessages_Locked()
1309 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 | 1104 auto& message_queue = entry.second; in OnAcceptBrokerClient() local
1105 while (!message_queue.empty()) { in OnAcceptBrokerClient()
1106 broker->RelayPortsMessage(destination, std::move(message_queue.front())); in OnAcceptBrokerClient()
1107 message_queue.pop(); in OnAcceptBrokerClient()
|
| /external/libmojo/ |
| D | Android.bp | 307 "mojo/edk/system/ports/message_queue.cc",
|