| /external/libchrome/mojo/core/ports/ |
| D | message_queue.cc | 22 MessageQueue::MessageQueue() : MessageQueue(kInitialSequenceNum) {} in MessageQueue() function in mojo::core::ports::MessageQueue
24 MessageQueue::MessageQueue(uint64_t next_sequence_num) in MessageQueue() function in mojo::core::ports::MessageQueue
30 MessageQueue::~MessageQueue() { in ~MessageQueue()
40 bool MessageQueue::HasNextMessage() const { in HasNextMessage()
44 void MessageQueue::GetNextMessage(std::unique_ptr<UserMessageEvent>* message, in GetNextMessage()
59 void MessageQueue::AcceptMessage(std::unique_ptr<UserMessageEvent> message, in AcceptMessage()
74 void MessageQueue::TakeAllMessages( in TakeAllMessages()
|
| D | message_queue.h | 31 class COMPONENT_EXPORT(MOJO_CORE_PORTS) MessageQueue { in COMPONENT_EXPORT()
33 explicit MessageQueue(); in COMPONENT_EXPORT()
34 explicit MessageQueue(uint64_t next_sequence_num); in COMPONENT_EXPORT()
35 ~MessageQueue(); in COMPONENT_EXPORT()
79 DISALLOW_COPY_AND_ASSIGN(MessageQueue); in COMPONENT_EXPORT()
|
| D | port.h | 129 MessageQueue message_queue;
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | message_queue.cc | 13 MessageQueue::MessageQueue() { in MessageQueue() function in mojo::test::MessageQueue
16 MessageQueue::~MessageQueue() { in ~MessageQueue()
19 bool MessageQueue::IsEmpty() const { in IsEmpty()
23 void MessageQueue::Push(Message* message) { in Push()
27 void MessageQueue::Pop(Message* message) { in Pop()
33 void MessageQueue::Pop() { in Pop()
|
| D | message_queue.h | 16 class MessageQueue {
18 MessageQueue();
19 ~MessageQueue();
37 DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| D | router_test_util.h | 18 class MessageQueue; variable
28 MessageAccumulator(MessageQueue* queue,
35 MessageQueue* queue_;
|
| D | multiplex_router_unittest.cc | 77 MessageQueue message_queue; in TEST_F()
124 MessageQueue message_queue; in TEST_F()
173 MessageQueue message_queue; in TEST_F()
254 MessageQueue message_queue; in TEST_F()
302 MessageQueue message_queue; in TEST_F()
|
| D | router_test_util.cc | 37 MessageAccumulator::MessageAccumulator(MessageQueue* queue, in MessageAccumulator()
|
| D | connector_unittest.cc | 49 MessageQueue queue_;
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | TrafficControlProxy.java | 128 MessageQueue clientPipe = new MessageQueue(clientIn, clientOut); in startWorkers()
129 MessageQueue serverPipe = new MessageQueue(serverIn, serverOut); in startWorkers()
139 private final MessageQueue queue;
141 Reader(MessageQueue queue) { in Reader()
162 private final MessageQueue queue;
164 Writer(MessageQueue queue) { in Writer()
185 private class MessageQueue { class in TrafficControlProxy
191 MessageQueue(DataInputStream inputStream, DataOutputStream outputStream) { in MessageQueue() method in TrafficControlProxy.MessageQueue
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowMessageQueue.java | 17 import android.os.MessageQueue;
34 @Implements(MessageQueue.class)
38 private MessageQueue realQueue;
97 …final boolean retval = directlyOn(realQueue, MessageQueue.class, "enqueueMessage", from(Message.cl… in enqueueMessage()
159 directlyOn(realQueue, MessageQueue.class, "removeSyncBarrier", from(int.class, token)); in removeSyncBarrier()
|
| D | ShadowMessage.java | 15 import android.os.MessageQueue;
140 private static ShadowMessageQueue shadowOf(MessageQueue mq) { in shadowOf()
|
| D | ShadowLooper.java | 9 import android.os.MessageQueue;
406 private static ShadowMessageQueue shadowOf(MessageQueue mq) { in shadowOf()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowMessageQueueTest.java | 18 import android.os.MessageQueue;
34 private MessageQueue queue;
250 private static void removeSyncBarrier(MessageQueue queue, int token) { in removeSyncBarrier()
252 MessageQueue.class, queue, "removeSyncBarrier", from(int.class, token)); in removeSyncBarrier()
255 private static int postSyncBarrier(MessageQueue queue) { in postSyncBarrier()
260 MessageQueue.class, in postSyncBarrier()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | JSDispatcher.kt | 18 inner class ScheduledMessageQueue : MessageQueue() { in <lambda>()
94 private class WindowMessageQueue(private val window: Window) : MessageQueue() {
127 internal abstract class MessageQueue : ArrayQueue<Runnable>() { class
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.hpp | 118 typedef de::ThreadSafeRingBuffer<Message> MessageQueue; typedef
150 MessageQueue m_msgQueue;
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/test/ |
| D | HandlerDispatcherTest.kt | 138 private val Looper.queue: MessageQueue
139 get() = Looper::class.java.getDeclaredMethod("getQueue").invoke(this) as MessageQueue
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| D | Engine.java | 4 import android.os.MessageQueue;
95 MessageQueue queue = Looper.myQueue(); in Engine()
273 private static class RefQueueIdleHandler implements MessageQueue.IdleHandler {
|
| /external/libchrome/base/android/java/src/org/chromium/base/ |
| D | TraceEvent.java | 8 import android.os.MessageQueue;
104 implements MessageQueue.IdleHandler {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | MessageQueueTest.kt | 13 private val queue = object : MessageQueue() { in <lambda>()
|
| /external/perfetto/test/trace_processor/dynamic/ |
| D | perf_sample_sc_annotated_callstack.out | 87 54,10,53,"aot","android.os.MessageQueue.next"
|
| /external/perfetto/test/trace_processor/profiling/ |
| D | perf_sample_sc.out | 87 105091321851304,7,"user","[NULL]",0,"cpu-clock",1,2029,"android.os.MessageQueue.next"
|