| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| D | message_queue.cc | 13 MessageQueue::MessageQueue() { in MessageQueue() function in mojo::internal::MessageQueue
16 MessageQueue::~MessageQueue() { in ~MessageQueue()
21 bool MessageQueue::IsEmpty() const { in IsEmpty()
25 Message* MessageQueue::Peek() { in Peek()
30 void MessageQueue::Push(Message* message) { in Push()
35 void MessageQueue::Pop(Message* message) { in Pop()
41 void MessageQueue::Pop() { in Pop()
|
| D | message_queue.h | 18 class MessageQueue {
20 MessageQueue();
21 ~MessageQueue();
41 MOJO_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| /external/chromium_org/third_party/webrtc/base/ |
| D | messagequeue.cc | 53 void MessageQueueManager::Add(MessageQueue *message_queue) { in Add()
56 void MessageQueueManager::AddInternal(MessageQueue *message_queue) { in AddInternal()
65 void MessageQueueManager::Remove(MessageQueue *message_queue) { in Remove()
71 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) { in RemoveInternal()
80 std::vector<MessageQueue *>::iterator iter; in RemoveInternal()
103 std::vector<MessageQueue *>::iterator iter; in ClearInternal()
111 MessageQueue::MessageQueue(SocketServer* ss) in MessageQueue() function in rtc::MessageQueue
127 MessageQueue::~MessageQueue() { in ~MessageQueue()
139 void MessageQueue::set_socketserver(SocketServer* ss) { in set_socketserver()
144 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 {
168 explicit MessageQueue(SocketServer* ss = NULL);
169 virtual ~MessageQueue();
249 DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| D | messagequeue_unittest.cc | 23 class MessageQueueTest: public testing::Test, public MessageQueue {
55 MessageQueue* q) { in DelayedPostsWithIdenticalTimesAreProcessedInFifoOrder()
76 MessageQueue q; in TEST_F()
79 MessageQueue q_nullss(&nullss); in TEST_F()
|
| D | socketserver.h | 18 class MessageQueue; variable
30 virtual void SetMessageQueue(MessageQueue* queue) {} in SetMessageQueue()
|
| D | win32socketserver.h | 93 explicit Win32SocketServer(MessageQueue* message_queue);
107 virtual void SetMessageQueue(MessageQueue* queue);
125 MessageQueue *message_queue_;
|
| D | natsocketfactory.h | 123 MessageQueue* queue() { return msg_queue_; } in queue()
137 virtual void SetMessageQueue(MessageQueue* queue) { in SetMessageQueue()
154 MessageQueue* msg_queue_;
|
| D | virtualsocketserver.h | 98 virtual void SetMessageQueue(MessageQueue* queue);
212 MessageQueue* msg_queue_;
|
| D | thread.cc | 139 : MessageQueue(ss), in Thread()
409 MessageQueue::Quit(); in Stop()
540 MessageQueue::Clear(phandler, id, removed); in Clear()
|
| D | firewallsocketserver.h | 67 virtual void SetMessageQueue(MessageQueue* queue) { in SetMessageQueue()
|
| D | thread.h | 100 class Thread : public MessageQueue {
|
| /external/chromium_org/third_party/WebKit/Source/wtf/ |
| D | MessageQueue.h | 53 class MessageQueue {
54 WTF_MAKE_NONCOPYABLE(MessageQueue);
56 MessageQueue() : m_killed(false) { } in MessageQueue() function
85 inline bool MessageQueue<DataType>::append(PassOwnPtr<DataType> message) in append()
94 inline void MessageQueue<DataType>::appendAndKill(PassOwnPtr<DataType> message) in appendAndKill()
104 inline bool MessageQueue<DataType>::appendAndCheckEmpty(PassOwnPtr<DataType> message) in appendAndCheckEmpty()
114 inline void MessageQueue<DataType>::prepend(PassOwnPtr<DataType> message) in prepend()
122 inline PassOwnPtr<DataType> MessageQueue<DataType>::waitForMessage() in waitForMessage()
131 …inline PassOwnPtr<DataType> MessageQueue<DataType>::waitForMessageWithTimeout(MessageQueueWaitResu… in waitForMessageWithTimeout()
158 inline PassOwnPtr<DataType> MessageQueue<DataType>::tryGetMessage() in tryGetMessage()
[all …]
|
| /external/chromium_org/mojo/public/cpp/bindings/tests/ |
| D | router_unittest.cc | 37 explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) { in MessageAccumulator()
46 internal::MessageQueue* queue_;
141 internal::MessageQueue message_queue; in TEST_F()
165 internal::MessageQueue message_queue; in TEST_F()
190 internal::MessageQueue message_queue; in TEST_F()
215 internal::MessageQueue message_queue; in TEST_F()
|
| /external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
| D | pingtask.h | 48 rtc::MessageQueue* message_queue, uint32 ping_period_millis,
62 rtc::MessageQueue* message_queue_;
|
| D | pingtask.cc | 13 rtc::MessageQueue* message_queue, in PingTask()
|
| /external/chromium_org/content/public/test/android/javatests/src/org/chromium/content/browser/test/ |
| D | NestedSystemMessageHandler.java | 10 import android.os.MessageQueue;
44 MessageQueue queue = Looper.myQueue(); in runNestedLoopTillIdle()
45 queue.addIdleHandler(new MessageQueue.IdleHandler() { in runNestedLoopTillIdle()
|
| /external/chromium_org/content/public/android/java/src/org/chromium/content/app/ |
| D | ContentApplication.java | 8 import android.os.MessageQueue;
33 Looper.myQueue().addIdleHandler(new MessageQueue.IdleHandler() { in onCreate()
|
| /external/chromium_org/content/child/ |
| D | resource_dispatcher.h | 107 typedef std::deque<IPC::Message*> MessageQueue; typedef
127 MessageQueue deferred_message_queue;
206 static void ReleaseResourcesInMessageQueue(MessageQueue* queue);
|
| D | webmessageportchannel_impl.h | 87 typedef std::queue<Message> MessageQueue; typedef
88 MessageQueue message_queue_;
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.hpp | 118 typedef de::ThreadSafeRingBuffer<Message> MessageQueue; typedef
150 MessageQueue m_msgQueue;
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| D | Engine.java | 5 import android.os.MessageQueue;
83 MessageQueue queue = Looper.myQueue(); in Engine()
212 private static class RefQueueIdleHandler implements MessageQueue.IdleHandler {
|
| /external/chromium_org/base/android/java/src/org/chromium/base/ |
| D | TraceEvent.java | 8 import android.os.MessageQueue;
66 implements MessageQueue.IdleHandler {
|
| /external/chromium_org/third_party/WebKit/Source/core/workers/ |
| D | WorkerThread.h | 123 MessageQueue<WorkerThreadTask> m_debuggerMessageQueue;
|
| /external/chromium_org/chrome/browser/service_process/ |
| D | service_process_control.h | 69 typedef std::queue<IPC::Message> MessageQueue; typedef
|