Home
last modified time | relevance | path

Searched refs:message_queue (Results 1 – 10 of 10) sorted by relevance

/external/libchrome/mojo/public/cpp/bindings/tests/
Dmultiplex_router_unittest.cc77 MessageQueue message_queue; in TEST_F() local
80 &request, std::make_unique<MessageAccumulator>(&message_queue, in TEST_F()
85 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
88 message_queue.Pop(&response); in TEST_F()
99 &request2, std::make_unique<MessageAccumulator>(&message_queue, in TEST_F()
104 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
106 message_queue.Pop(&response); in TEST_F()
124 MessageQueue message_queue; in TEST_F() local
126 &request, std::make_unique<MessageAccumulator>(&message_queue)); in TEST_F()
131 EXPECT_FALSE(message_queue.IsEmpty()); in TEST_F()
[all …]
/external/libchrome/mojo/core/ports/
Dnode.cc85 uint64_t next_sequence_num = port->message_queue.next_sequence_num(); in CanAcceptMoreMessages()
271 port->message_queue.TakeAllMessages(&undelivered_messages); in ClosePort()
304 port_status->has_messages = port->message_queue.HasNextMessage(); in GetStatus()
309 port->message_queue.queued_message_count(); in GetStatus()
310 port_status->queued_num_bytes = port->message_queue.queued_num_bytes(); in GetStatus()
335 port->message_queue.GetNextMessage(message, filter); in GetMessage()
349 locker.port()->message_queue.set_signalable(true); in GetMessage()
503 port->message_queue.AcceptMessage(std::move(message), &has_next_message); in OnUserMessage()
814 locker.port()->message_queue.TakeAllMessages(&messages); in ErasePort()
990 port->message_queue.next_sequence_num(); in ConvertToProxy()
[all …]
Dport.cc16 message_queue(next_sequence_num_to_receive), in Port()
Dport.h129 MessageQueue message_queue; variable
/external/angle/src/tests/
Dcapture_replay_tests.py740 def RunTests(args, worker_id, job_queue, result_list, message_queue): argument
751 message_queue.put("Starting {} tests on worker {}. Unstarted jobs: {}".format(
759 message_queue.put(str(test_batch.GetResults()))
764 message_queue.put(str(test_batch.GetResults()))
772 message_queue.put(str(test_batch.GetResults()))
777 message_queue.put(str(test_batch.GetResults()))
785 message_queue.put("RunTestsException: %s\n%s" % (repr(e), traceback.format_exc()))
889 message_queue = manager.Queue()
895 target=RunTests, args=(args, worker_id, job_queue, result_list, message_queue))
905 while not message_queue.empty():
[all …]
/external/webrtc/rtc_base/
Dthread.cc123 void ThreadManager::Add(Thread* message_queue) { in Add() argument
124 return Instance()->AddInternal(message_queue); in Add()
126 void ThreadManager::AddInternal(Thread* message_queue) { in AddInternal() argument
130 message_queues_.push_back(message_queue); in AddInternal()
134 void ThreadManager::Remove(Thread* message_queue) { in Remove() argument
135 return Instance()->RemoveInternal(message_queue); in Remove()
137 void ThreadManager::RemoveInternal(Thread* message_queue) { in RemoveInternal() argument
143 iter = absl::c_find(message_queues_, message_queue); in RemoveInternal()
148 RemoveFromSendGraph(message_queue); in RemoveInternal()
Dthread.h81 static void Add(Thread* message_queue);
82 static void Remove(Thread* message_queue);
129 void AddInternal(Thread* message_queue);
130 void RemoveInternal(Thread* message_queue);
/external/rust/crates/futures-channel/src/mpsc/
Dmod.rs274 message_queue: Queue<T>, field
293 message_queue: Queue<T>, field
372 message_queue: Queue::new(), in channel()
405 message_queue: Queue::new(), in unbounded()
443 self.inner.message_queue.push(msg); in queue_push_and_signal()
581 self.inner.message_queue.push(msg); in queue_push_and_signal()
1038 match unsafe { inner.message_queue.pop_spin() } { in next_message()
1186 match unsafe { inner.message_queue.pop_spin() } { in next_message()
/external/libchrome/mojo/core/
Dnode_controller.cc948 auto& message_queue = entry.second; in OnAcceptBrokerClient() local
949 while (!message_queue.empty()) { in OnAcceptBrokerClient()
950 broker->RelayEventMessage(destination, std::move(message_queue.front())); in OnAcceptBrokerClient()
951 message_queue.pop(); in OnAcceptBrokerClient()
/external/libchrome/
DBUILD.gn723 "mojo/core/ports/message_queue.cc",