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

12

/external/chromium_org/mojo/public/bindings/lib/
H A Dmessage_queue.cc14 MessageQueue::MessageQueue() { function in class:mojo::MessageQueue
17 MessageQueue::~MessageQueue() {
22 bool MessageQueue::IsEmpty() const {
26 Message* MessageQueue::Peek() {
31 void MessageQueue::Push(Message* message) {
36 void MessageQueue::Pop(Message* message) {
42 void MessageQueue::Pop() {
H A Dmessage_queue.h17 class MessageQueue { class in namespace:mojo
19 MessageQueue();
20 ~MessageQueue();
40 MOJO_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
H A Dconnector.h67 MessageQueue write_queue_;
/external/chromium/third_party/libjingle/source/talk/base/
H A Dsocketserver.h35 class MessageQueue;
47 virtual void SetMessageQueue(MessageQueue* queue) {}
H A Dmessagequeue.cc65 void MessageQueueManager::Add(MessageQueue *message_queue) {
74 void MessageQueueManager::Remove(MessageQueue *message_queue) {
76 // If this is the last MessageQueue, destroy the manager as well so that
83 std::vector<MessageQueue *>::iterator iter;
100 std::vector<MessageQueue *>::iterator iter;
106 // MessageQueue
108 MessageQueue::MessageQueue(SocketServer* ss) function in class:talk_base::MessageQueue
112 // Currently, MessageQueue holds a socket server, and is the base class for
114 // server, and provide it to the MessageQueue, sinc
[all...]
H A Dmessagequeue.h48 class MessageQueue;
56 void Add(MessageQueue *message_queue);
57 void Remove(MessageQueue *message_queue);
66 std::vector<MessageQueue *> message_queues_;
159 class MessageQueue { class in namespace:talk_base
161 explicit MessageQueue(SocketServer* ss = NULL);
162 virtual ~MessageQueue();
167 // Note: The behavior of MessageQueue has changed. When a MQ is stopped,
171 // we eliminate the race condition when an MessageHandler and MessageQueue
227 // The SocketServer is not owned by MessageQueue
[all...]
H A Dwin32socketserver.h109 explicit Win32SocketServer(MessageQueue *message_queue);
115 virtual void SetMessageQueue(MessageQueue* queue);
133 MessageQueue *message_queue_;
H A Dfirewallsocketserver.h80 virtual void SetMessageQueue(MessageQueue* queue) {
H A Dthread.h114 class Thread : public MessageQueue {
147 // function which will exit the base MessageQueue without terminating the
159 // From MessageQueue
/external/chromium_org/third_party/libjingle/source/talk/base/
H A Dsocketserver.h35 class MessageQueue;
47 virtual void SetMessageQueue(MessageQueue* queue) {}
H A Dmessagequeue.cc65 void MessageQueueManager::Add(MessageQueue *message_queue) {
68 void MessageQueueManager::AddInternal(MessageQueue *message_queue) {
77 void MessageQueueManager::Remove(MessageQueue *message_queue) {
83 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) {
85 // If this is the last MessageQueue, destroy the manager as well so that
92 std::vector<MessageQueue *>::iterator iter;
115 std::vector<MessageQueue *>::iterator iter;
121 // MessageQueue
123 MessageQueue::MessageQueue(SocketServe function in class:talk_base::MessageQueue
[all...]
H A Dmessagequeue.h50 class MessageQueue;
56 static void Add(MessageQueue *message_queue);
57 static void Remove(MessageQueue *message_queue);
72 void AddInternal(MessageQueue *message_queue);
73 void RemoveInternal(MessageQueue *message_queue);
78 std::vector<MessageQueue *> message_queues_;
182 class MessageQueue { class in namespace:talk_base
184 explicit MessageQueue(SocketServer* ss = NULL);
185 virtual ~MessageQueue();
190 // Note: The behavior of MessageQueue ha
[all...]
H A Dmessagequeue_unittest.cc39 class MessageQueueTest: public testing::Test, public MessageQueue {
71 MessageQueue* q) {
92 MessageQueue q;
95 MessageQueue q_nullss(&nullss);
H A Dnatsocketfactory.h140 MessageQueue* queue() { return msg_queue_; }
154 virtual void SetMessageQueue(MessageQueue* queue) {
171 MessageQueue* msg_queue_;
H A Dwin32socketserver.h110 explicit Win32SocketServer(MessageQueue* message_queue);
124 virtual void SetMessageQueue(MessageQueue* queue);
142 MessageQueue *message_queue_;
H A Dvirtualsocketserver.h114 virtual void SetMessageQueue(MessageQueue* queue);
225 MessageQueue* msg_queue_;
/external/chromium_org/third_party/WebKit/Source/wtf/
H A DMessageQueue.h50 // Essentially, MessageQueue acts as a queue of OwnPtr<DataType>.
52 class MessageQueue { class in namespace:WTF
53 WTF_MAKE_NONCOPYABLE(MessageQueue);
55 MessageQueue() : m_killed(false) { } function in class:WTF::MessageQueue
56 ~MessageQueue();
91 MessageQueue<DataType>::~MessageQueue()
97 inline bool MessageQueue<DataType>::append(PassOwnPtr<DataType> message)
106 inline void MessageQueue<DataType>::appendAndKill(PassOwnPtr<DataType> message)
116 inline bool MessageQueue<DataTyp
[all...]
/external/chromium_org/content/public/android/java/src/org/chromium/content/app/
H A DContentApplication.java8 import android.os.MessageQueue;
32 Looper.myQueue().addIdleHandler(new MessageQueue.IdleHandler() {
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
H A Dpingtask.h48 talk_base::MessageQueue* message_queue, uint32 ping_period_millis,
62 talk_base::MessageQueue* message_queue_;
H A Dpingtask.cc13 talk_base::MessageQueue* message_queue,
/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/third_party/WebKit/Source/core/workers/
H A DWorkerRunLoop.h37 #include "wtf/MessageQueue.h"
87 MessageQueue<Task> m_messageQueue;
/external/chromium_org/content/child/
H A Dwebmessageportchannel_impl.h74 typedef std::queue<Message> MessageQueue; typedef in class:content::WebMessagePortChannelImpl
75 MessageQueue message_queue_;
H A Dresource_dispatcher.h84 typedef std::deque<IPC::Message*> MessageQueue; typedef in class:content::ResourceDispatcher
102 MessageQueue deferred_message_queue;
191 static void ReleaseResourcesInMessageQueue(MessageQueue* queue);
/external/chromium/chrome/browser/service/
H A Dservice_process_control.h45 typedef std::queue<IPC::Message> MessageQueue; typedef in class:ServiceProcessControl

Completed in 793 milliseconds

12