| /external/webrtc/webrtc/base/ |
| D | messagequeue.cc | 55 void MessageQueueManager::Add(MessageQueue *message_queue) { in Add()
58 void MessageQueueManager::AddInternal(MessageQueue *message_queue) { in AddInternal()
69 void MessageQueueManager::Remove(MessageQueue *message_queue) { in Remove()
75 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) { in RemoveInternal()
86 std::vector<MessageQueue *>::iterator iter; in RemoveInternal()
111 std::vector<MessageQueue *>::iterator iter; in ClearInternal()
119 MessageQueue::MessageQueue(SocketServer* ss) in MessageQueue() function in rtc::MessageQueue
135 MessageQueue::~MessageQueue() { in ~MessageQueue()
147 void MessageQueue::set_socketserver(SocketServer* ss) { in set_socketserver()
152 void MessageQueue::Quit() { in Quit()
[all …]
|
| D | messagequeue.h | 34 class MessageQueue; variable
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);
62 std::vector<MessageQueue *> message_queues_;
166 class MessageQueue {
170 explicit MessageQueue(SocketServer* ss = NULL);
171 virtual ~MessageQueue();
257 RTC_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| D | messagequeue_unittest.cc | 22 class MessageQueueTest: public testing::Test, public MessageQueue {
54 MessageQueue* q) { in DelayedPostsWithIdenticalTimesAreProcessedInFifoOrder()
75 MessageQueue q; in TEST_F()
78 MessageQueue q_nullss(&nullss); in TEST_F()
|
| D | socketserver.h | 18 class MessageQueue; variable
32 virtual void SetMessageQueue(MessageQueue* queue) {} in SetMessageQueue()
|
| D | natsocketfactory.h | 128 MessageQueue* queue() { return msg_queue_; } in queue()
142 void SetMessageQueue(MessageQueue* queue) override;
154 MessageQueue* msg_queue_;
|
| D | win32socketserver.h | 93 explicit Win32SocketServer(MessageQueue* message_queue);
107 virtual void SetMessageQueue(MessageQueue* queue);
125 MessageQueue *message_queue_;
|
| D | thread.cc | 142 : MessageQueue(ss), in Thread()
316 MessageQueue::Quit(); in Stop()
456 MessageQueue::Clear(phandler, id, removed); in Clear()
|
| /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()
|
| /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 | 17 import android.os.MessageQueue;
33 private MessageQueue queue;
249 private static void removeSyncBarrier(MessageQueue queue, int token) { in removeSyncBarrier()
251 MessageQueue.class, queue, "removeSyncBarrier", from(int.class, token)); in removeSyncBarrier()
254 private static int postSyncBarrier(MessageQueue queue) { in postSyncBarrier()
259 MessageQueue.class, in postSyncBarrier()
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | pingtask.h | 31 rtc::MessageQueue* message_queue,
46 rtc::MessageQueue* message_queue_;
|
| D | pingtask.cc | 20 rtc::MessageQueue* message_queue, in PingTask()
|
| /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 {
|