Searched refs:MessageQueue (Results 1 - 25 of 34) sorted by relevance

12

/external/chromium_org/mojo/public/cpp/bindings/lib/
H A Dmessage_queue.cc13 MessageQueue::MessageQueue() { function in class:mojo::internal::MessageQueue
16 MessageQueue::~MessageQueue() {
21 bool MessageQueue::IsEmpty() const {
25 Message* MessageQueue::Peek() {
30 void MessageQueue::Push(Message* message) {
35 void MessageQueue::Pop(Message* message) {
41 void MessageQueue::Pop() {
H A Dmessage_queue.h18 class MessageQueue { class in namespace:mojo::internal
20 MessageQueue();
21 ~MessageQueue();
41 MOJO_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
/external/chromium_org/third_party/webrtc/base/
H A Dsocketserver.h18 class MessageQueue;
30 virtual void SetMessageQueue(MessageQueue* queue) {}
H A Dmessagequeue.cc53 void MessageQueueManager::Add(MessageQueue *message_queue) {
56 void MessageQueueManager::AddInternal(MessageQueue *message_queue) {
65 void MessageQueueManager::Remove(MessageQueue *message_queue) {
71 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) {
73 // If this is the last MessageQueue, destroy the manager as well so that
80 std::vector<MessageQueue *>::iterator iter;
103 std::vector<MessageQueue *>::iterator iter;
109 // MessageQueue
111 MessageQueue::MessageQueue(SocketServe function in class:rtc::MessageQueue
[all...]
H A Dmessagequeue.h34 class MessageQueue;
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 { class in namespace:rtc
168 explicit MessageQueue(SocketServer* ss = NULL);
169 virtual ~MessageQueue();
174 // Note: The behavior of MessageQueue ha
[all...]
H A Dmessagequeue_unittest.cc23 class MessageQueueTest: public testing::Test, public MessageQueue {
55 MessageQueue* q) {
76 MessageQueue q;
79 MessageQueue q_nullss(&nullss);
H A Dnatsocketfactory.h123 MessageQueue* queue() { return msg_queue_; }
137 virtual void SetMessageQueue(MessageQueue* queue) {
154 MessageQueue* msg_queue_;
H A Dwin32socketserver.h93 explicit Win32SocketServer(MessageQueue* message_queue);
107 virtual void SetMessageQueue(MessageQueue* queue);
125 MessageQueue *message_queue_;
H A Dvirtualsocketserver.h98 virtual void SetMessageQueue(MessageQueue* queue);
212 MessageQueue* msg_queue_;
H A Dfirewallsocketserver.h67 virtual void SetMessageQueue(MessageQueue* queue) {
H A Dthread.cc139 : MessageQueue(ss),
409 MessageQueue::Quit();
463 // MessageQueue, that weren't relevant to this Send. Losing these WakeUps can
540 MessageQueue::Clear(phandler, id, removed);
H A Dthread.h100 class Thread : public MessageQueue {
147 // function which will exit the base MessageQueue without terminating the
173 // From MessageQueue
/external/chromium_org/third_party/WebKit/Source/wtf/
H A DMessageQueue.h51 // Essentially, MessageQueue acts as a queue of OwnPtr<DataType>.
53 class MessageQueue { class in namespace:WTF
54 WTF_MAKE_NONCOPYABLE(MessageQueue);
56 MessageQueue() : m_killed(false) { } function in class:WTF::MessageQueue
85 inline bool MessageQueue<DataType>::append(PassOwnPtr<DataType> message)
94 inline void MessageQueue<DataType>::appendAndKill(PassOwnPtr<DataType> message)
104 inline bool MessageQueue<DataType>::appendAndCheckEmpty(PassOwnPtr<DataType> message)
114 inline void MessageQueue<DataType>::prepend(PassOwnPtr<DataType> message)
122 inline PassOwnPtr<DataType> MessageQueue<DataType>::waitForMessage()
131 inline PassOwnPtr<DataType> MessageQueue<DataTyp
[all...]
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
H A Dpingtask.h48 rtc::MessageQueue* message_queue, uint32 ping_period_millis,
62 rtc::MessageQueue* message_queue_;
H A Dpingtask.cc13 rtc::MessageQueue* message_queue,
/external/chromium_org/content/public/android/java/src/org/chromium/content/app/
H A DContentApplication.java8 import android.os.MessageQueue;
33 Looper.myQueue().addIdleHandler(new MessageQueue.IdleHandler() {
/external/chromium_org/content/public/test/android/javatests/src/org/chromium/content/browser/test/
H A DNestedSystemMessageHandler.java10 import android.os.MessageQueue;
23 * in nested mode, we use reflection to retreive messages from the MessageQueue
37 * Processes messages from the current MessageQueue till the queue becomes idle.
44 MessageQueue queue = Looper.myQueue();
45 queue.addIdleHandler(new MessageQueue.IdleHandler() {
/external/chromium_org/content/child/
H A Dwebmessageportchannel_impl.h87 typedef std::queue<Message> MessageQueue; typedef in class:content::WebMessagePortChannelImpl
88 MessageQueue message_queue_;
H A Dresource_dispatcher.h107 typedef std::deque<IPC::Message*> MessageQueue; typedef in class:content::ResourceDispatcher
127 MessageQueue deferred_message_queue;
206 static void ReleaseResourcesInMessageQueue(MessageQueue* queue);
/external/chromium_org/mojo/public/cpp/bindings/tests/
H A Drouter_unittest.cc37 explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) {
46 internal::MessageQueue* queue_;
141 internal::MessageQueue message_queue;
165 internal::MessageQueue message_queue;
190 internal::MessageQueue message_queue;
215 internal::MessageQueue message_queue;
/external/deqp/framework/platform/android/
H A DtcuAndroidRenderActivity.hpp118 typedef de::ThreadSafeRingBuffer<Message> MessageQueue; typedef in namespace:tcu::Android
150 MessageQueue m_msgQueue;
/external/chromium_org/third_party/WebKit/Source/core/workers/
H A DWorkerThread.h37 #include "wtf/MessageQueue.h"
123 MessageQueue<WorkerThreadTask> m_debuggerMessageQueue;
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/
H A DEngine.java5 import android.os.MessageQueue;
83 MessageQueue queue = Looper.myQueue();
212 private static class RefQueueIdleHandler implements MessageQueue.IdleHandler {
/external/chromium_org/base/android/java/src/org/chromium/base/
H A DTraceEvent.java8 import android.os.MessageQueue;
66 implements MessageQueue.IdleHandler {
/external/chromium_org/chrome/browser/service_process/
H A Dservice_process_control.h69 typedef std::queue<IPC::Message> MessageQueue; typedef in class:ServiceProcessControl

Completed in 776 milliseconds

12