/external/chromium_org/mojo/public/bindings/lib/ |
H A D | message_queue.cc | 14 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 D | message_queue.h | 17 class MessageQueue { class in namespace:mojo 19 MessageQueue(); 20 ~MessageQueue(); 40 MOJO_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
H A D | connector.h | 67 MessageQueue write_queue_;
|
/external/chromium/third_party/libjingle/source/talk/base/ |
H A D | socketserver.h | 35 class MessageQueue; 47 virtual void SetMessageQueue(MessageQueue* queue) {}
|
H A D | messagequeue.cc | 65 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 D | messagequeue.h | 48 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 D | win32socketserver.h | 109 explicit Win32SocketServer(MessageQueue *message_queue); 115 virtual void SetMessageQueue(MessageQueue* queue); 133 MessageQueue *message_queue_;
|
H A D | firewallsocketserver.h | 80 virtual void SetMessageQueue(MessageQueue* queue) {
|
H A D | thread.h | 114 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 D | socketserver.h | 35 class MessageQueue; 47 virtual void SetMessageQueue(MessageQueue* queue) {}
|
H A D | messagequeue.cc | 65 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 D | messagequeue.h | 50 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 D | messagequeue_unittest.cc | 39 class MessageQueueTest: public testing::Test, public MessageQueue { 71 MessageQueue* q) { 92 MessageQueue q; 95 MessageQueue q_nullss(&nullss);
|
H A D | natsocketfactory.h | 140 MessageQueue* queue() { return msg_queue_; } 154 virtual void SetMessageQueue(MessageQueue* queue) { 171 MessageQueue* msg_queue_;
|
H A D | win32socketserver.h | 110 explicit Win32SocketServer(MessageQueue* message_queue); 124 virtual void SetMessageQueue(MessageQueue* queue); 142 MessageQueue *message_queue_;
|
H A D | virtualsocketserver.h | 114 virtual void SetMessageQueue(MessageQueue* queue); 225 MessageQueue* msg_queue_;
|
/external/chromium_org/third_party/WebKit/Source/wtf/ |
H A D | MessageQueue.h | 50 // 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 D | ContentApplication.java | 8 import android.os.MessageQueue; 32 Looper.myQueue().addIdleHandler(new MessageQueue.IdleHandler() {
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | pingtask.h | 48 talk_base::MessageQueue* message_queue, uint32 ping_period_millis, 62 talk_base::MessageQueue* message_queue_;
|
H A D | pingtask.cc | 13 talk_base::MessageQueue* message_queue,
|
/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/third_party/WebKit/Source/core/workers/ |
H A D | WorkerRunLoop.h | 37 #include "wtf/MessageQueue.h" 87 MessageQueue<Task> m_messageQueue;
|
/external/chromium_org/content/child/ |
H A D | webmessageportchannel_impl.h | 74 typedef std::queue<Message> MessageQueue; typedef in class:content::WebMessagePortChannelImpl 75 MessageQueue message_queue_;
|
H A D | resource_dispatcher.h | 84 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 D | service_process_control.h | 45 typedef std::queue<IPC::Message> MessageQueue; typedef in class:ServiceProcessControl
|