/external/chromium_org/mojo/public/cpp/bindings/lib/ |
H A D | message_queue.cc | 13 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 D | message_queue.h | 18 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 D | socketserver.h | 18 class MessageQueue; 30 virtual void SetMessageQueue(MessageQueue* queue) {}
|
H A D | messagequeue.cc | 53 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 D | messagequeue.h | 34 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 D | messagequeue_unittest.cc | 23 class MessageQueueTest: public testing::Test, public MessageQueue { 55 MessageQueue* q) { 76 MessageQueue q; 79 MessageQueue q_nullss(&nullss);
|
H A D | natsocketfactory.h | 123 MessageQueue* queue() { return msg_queue_; } 137 virtual void SetMessageQueue(MessageQueue* queue) { 154 MessageQueue* msg_queue_;
|
H A D | win32socketserver.h | 93 explicit Win32SocketServer(MessageQueue* message_queue); 107 virtual void SetMessageQueue(MessageQueue* queue); 125 MessageQueue *message_queue_;
|
H A D | virtualsocketserver.h | 98 virtual void SetMessageQueue(MessageQueue* queue); 212 MessageQueue* msg_queue_;
|
H A D | firewallsocketserver.h | 67 virtual void SetMessageQueue(MessageQueue* queue) {
|
H A D | thread.cc | 139 : 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 D | thread.h | 100 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 D | MessageQueue.h | 51 // 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 D | pingtask.h | 48 rtc::MessageQueue* message_queue, uint32 ping_period_millis, 62 rtc::MessageQueue* message_queue_;
|
H A D | pingtask.cc | 13 rtc::MessageQueue* message_queue,
|
/external/chromium_org/content/public/android/java/src/org/chromium/content/app/ |
H A D | ContentApplication.java | 8 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 D | NestedSystemMessageHandler.java | 10 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 D | webmessageportchannel_impl.h | 87 typedef std::queue<Message> MessageQueue; typedef in class:content::WebMessagePortChannelImpl 88 MessageQueue message_queue_;
|
H A D | resource_dispatcher.h | 107 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 D | router_unittest.cc | 37 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 D | tcuAndroidRenderActivity.hpp | 118 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 D | WorkerThread.h | 37 #include "wtf/MessageQueue.h" 123 MessageQueue<WorkerThreadTask> m_debuggerMessageQueue;
|
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
H A D | Engine.java | 5 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 D | TraceEvent.java | 8 import android.os.MessageQueue; 66 implements MessageQueue.IdleHandler {
|
/external/chromium_org/chrome/browser/service_process/ |
H A D | service_process_control.h | 69 typedef std::queue<IPC::Message> MessageQueue; typedef in class:ServiceProcessControl
|