| /external/perfetto/test/trace_processor/diff_tests/metrics/android/ |
| D | android_monitor_contention.out | 45 blocking_method: "android.os.Message android.os.MessageQueue.next()"
46 blocked_method: "boolean android.os.MessageQueue.enqueueMessage(android.os.Message, long)"
47 short_blocking_method: "android.os.MessageQueue.next"
48 short_blocked_method: "android.os.MessageQueue.enqueueMessage"
49 blocking_src: "MessageQueue.java:337"
50 blocked_src: "MessageQueue.java:554"
76 blocking_method: "android.os.Message android.os.MessageQueue.next()"
77 blocked_method: "boolean android.os.MessageQueue.enqueueMessage(android.os.Message, long)"
78 short_blocking_method: "android.os.MessageQueue.next"
79 short_blocked_method: "android.os.MessageQueue.enqueueMessage"
[all …]
|
| /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()
|
| /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()
|
| /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/perfetto/protos/perfetto/trace/android/ |
| D | android_track_event.proto | 24 // Looper and MessageQueue.
26 // Thread name sending a message on the MessageQueue.
28 // Thread name receiving a message on the MessageQueue.
30 // User-defined message code for messages in the MessageQueue.
32 // Intended delay in millis before a message on the MessageQueue is executed.
68 // MessageQueue messages.
|
| /external/openthread/tests/unit/ |
| D | test_message_queue.cpp | 49 void VerifyMessageQueueContent(MessageQueue &aMessageQueue, int aExpectedLength, ...) in VerifyMessageQueueContent()
51 const MessageQueue &constQueue = aMessageQueue; in VerifyMessageQueueContent()
107 MessageQueue messageQueue; in TestMessageQueue()
109 MessageQueue::Info info; in TestMessageQueue()
131 messageQueue.Enqueue(*messages[0], MessageQueue::kQueuePositionHead); in TestMessageQueue()
176 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionHead); in TestMessageQueue()
188 messageQueue.Enqueue(*messages[1], MessageQueue::kQueuePositionHead); in TestMessageQueue()
192 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionTail); in TestMessageQueue()
|
| /external/cronet/stable/base/test/android/javatests/src/org/chromium/base/test/util/ |
| D | LooperUtils.java | 10 import android.os.MessageQueue;
18 private static final Method sNextMethod = getMethod(MessageQueue.class, "next");
50 MessageQueue queue = Looper.myQueue(); in runSingleNestedLooperTask()
|
| /external/cronet/tot/base/test/android/javatests/src/org/chromium/base/test/util/ |
| D | LooperUtils.java | 10 import android.os.MessageQueue;
18 private static final Method sNextMethod = getMethod(MessageQueue.class, "next");
50 MessageQueue queue = Looper.myQueue(); in runSingleNestedLooperTask()
|
| /external/openthread/src/core/coap/ |
| D | coap_message.hpp | 162 friend class MessageQueue;
935 class MessageQueue : public ot::MessageQueue class
941 MessageQueue(void) = default;
948 Message *GetHead(void) { return static_cast<Message *>(ot::MessageQueue::GetHead()); } in GetHead()
955 …const Message *GetHead(void) const { return static_cast<const Message *>(ot::MessageQueue::GetHead… in GetHead()
970 …void Enqueue(Message &aMessage, QueuePosition aPosition) { ot::MessageQueue::Enqueue(aMessage, aPo… in Enqueue()
977 void Dequeue(Message &aMessage) { ot::MessageQueue::Dequeue(aMessage); } in Dequeue()
984 void DequeueAndFree(Message &aMessage) { ot::MessageQueue::DequeueAndFree(aMessage); } in DequeueAndFree()
|
| D | coap.hpp | 313 const MessageQueue &GetResponses(void) const { return mQueue; } in GetResponses()
331 MessageQueue mQueue;
727 const MessageQueue &GetRequestMessages(void) const { return mPendingRequests; } in GetRequestMessages()
734 const MessageQueue &GetCachedResponses(void) const { return mResponsesQueue.GetResponses(); } in GetCachedResponses()
874 MessageQueue mPendingRequests;
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowLegacyMessageQueue.java | 10 import android.os.MessageQueue;
35 @Implements(value = MessageQueue.class, isInAndroidSdk = false)
38 @RealObject private MessageQueue realQueue;
162 @ForType(MessageQueue.class)
|
| D | ShadowDisplayEventReceiver.java | 13 import android.os.MessageQueue;
61 WeakReference<DisplayEventReceiver> receiver, MessageQueue msgQueue, int vsyncSource) { in nativeInit()
67 WeakReference<DisplayEventReceiver> receiver, MessageQueue msgQueue) { in nativeInit()
72 protected static long nativeInit(DisplayEventReceiver receiver, MessageQueue msgQueue) { in nativeInit()
80 MessageQueue msgQueue, in nativeInit()
90 MessageQueue msgQueue, in nativeInit()
|
| D | ShadowMessageQueue.java | 4 import android.os.MessageQueue;
14 @Implements(value = MessageQueue.class, shadowPicker = ShadowMessageQueue.Picker.class)
|
| D | ShadowPausedMessageQueue.java | 11 import android.os.MessageQueue;
12 import android.os.MessageQueue.IdleHandler;
38 @Implements(value = MessageQueue.class, isInAndroidSdk = false)
41 @RealObject private MessageQueue realQueue;
137 MessageQueue realQueue = nativeQueueRegistry.getNativeObject(ptr).realQueue; in nativeWake()
435 @ForType(MessageQueue.class)
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowPausedMessageQueueTest.java | 8 import android.os.MessageQueue;
23 private MessageQueue queue;
30 MessageQueue.class, ClassParameter.from(boolean.class, true)); in setUp()
108 MessageQueue mainQueue = Looper.getMainLooper().getQueue(); in assertMainQueueEmptyAndAdd()
|
| D | ShadowLegacyMessageQueueTest.java | 16 import android.os.MessageQueue;
38 private MessageQueue queue;
257 private static void removeSyncBarrier(MessageQueue queue, int token) { in removeSyncBarrier()
259 MessageQueue.class, queue, "removeSyncBarrier", ClassParameter.from(int.class, token)); in removeSyncBarrier()
262 private static int postSyncBarrier(MessageQueue queue) { in postSyncBarrier()
267 MessageQueue.class, in postSyncBarrier()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jsAndWasmJsShared/src/internal/ |
| D | JSDispatcher.kt | 12 internal expect class ScheduledMessageQueue(dispatcher: SetTimeoutBasedDispatcher) : MessageQueue { in w3cSetTimeout()
18 internal expect class WindowMessageQueue(window: W3CWindow) : MessageQueue {
106 internal abstract class MessageQueue : MutableList<Runnable> by ArrayDeque() { in toString() class
|
| /external/openthread/src/core/common/ |
| D | message.hpp | 148 class MessageQueue;
283 friend class MessageQueue;
1376 MessageQueue *GetMessageQueue(void) const in GetMessageQueue()
1378 … return !GetMetadata().mInPriorityQ ? static_cast<MessageQueue *>(GetMetadata().mQueue) : nullptr; in GetMessageQueue()
1553 void SetMessageQueue(MessageQueue *aMessageQueue);
1572 class MessageQueue : public otMessageQueue class
1593 MessageQueue(void) { SetTail(nullptr); } in MessageQueue() function in ot::MessageQueue
1678 friend class MessageQueue;
1812 friend class MessageQueue;
1908 DefineCoreType(otMessageQueue, MessageQueue);
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | JSDispatcher.kt | 20 …ssageQueue actual constructor(private val dispatcher: SetTimeoutBasedDispatcher) : MessageQueue() { in <lambda>()
42 …ctual class WindowMessageQueue actual constructor(private val window: W3CWindow) : MessageQueue() {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/wasmJs/src/ |
| D | JSDispatcher.kt | 21 …ssageQueue actual constructor(private val dispatcher: SetTimeoutBasedDispatcher) : MessageQueue() { in clearTimeout()
62 internal actual class WindowMessageQueue actual constructor(window: W3CWindow) : MessageQueue() { in subscribeToWindowMessages()
|
| /external/openthread/src/core/net/ |
| D | ip6_mpl.hpp | 196 const MessageQueue &GetBufferedMessageSet(void) const { return mBufferedMessageSet; } in GetBufferedMessageSet()
239 MessageQueue mBufferedMessageSet;
|