/external/chromium/third_party/libjingle/source/talk/base/ |
socketserver.h | 35 class MessageQueue; 47 virtual void SetMessageQueue(MessageQueue* queue) {}
|
messagequeue.cc | 38 #include "talk/base/messagequeue.h" 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) 112 // Currently, MessageQueue holds a socket server, and is the base class fo [all...] |
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 { 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...] |
/external/chromium_org/third_party/libjingle/source/talk/base/ |
socketserver.h | 35 class MessageQueue; 47 virtual void SetMessageQueue(MessageQueue* queue) {}
|
messagequeue.cc | 34 #include "talk/base/messagequeue.h" 61 void MessageQueueManager::Add(MessageQueue *message_queue) { 70 void MessageQueueManager::Remove(MessageQueue *message_queue) { 72 // If this is the last MessageQueue, destroy the manager as well so that 79 std::vector<MessageQueue *>::iterator iter; 96 std::vector<MessageQueue *>::iterator iter; 102 // MessageQueue 104 MessageQueue::MessageQueue(SocketServer* ss) 108 // Currently, MessageQueue holds a socket server, and is the base class fo [all...] |
messagequeue_unittest.cc | 28 #include "talk/base/messagequeue.h" 39 class MessageQueueTest: public testing::Test, public MessageQueue { 71 MessageQueue* q) { 92 MessageQueue q; 95 MessageQueue q_nullss(&nullss);
|
/frameworks/base/core/jni/ |
android_os_MessageQueue.h | 25 class MessageQueue : public RefBase { 58 MessageQueue(); 59 virtual ~MessageQueue(); 65 /* Gets the native object associated with a MessageQueue. */ 66 extern sp<MessageQueue> android_os_MessageQueue_getMessageQueue(
|
android_os_MessageQueue.cpp | 17 #define LOG_TAG "MessageQueue-JNI" 29 jfieldID mPtr; // native object attached to the DVM MessageQueue 33 class NativeMessageQueue : public MessageQueue { 50 MessageQueue::MessageQueue() { 53 MessageQueue::~MessageQueue() { 56 bool MessageQueue::raiseAndClearException(JNIEnv* env, const char* msg) { 85 ALOGE("Exception in MessageQueue callback: %s", msg); 112 sp<MessageQueue> android_os_MessageQueue_getMessageQueue(JNIEnv* env, jobject messageQueueObj) [all...] |
/hardware/ti/omap4xxx/libtiutils/ |
MessageQueue.h | 64 class MessageQueue 68 MessageQueue(); 69 ~MessageQueue(); 92 static int waitForMsg(MessageQueue *queue1, MessageQueue *queue2=0, MessageQueue *queue3=0, int timeout = 0);
|
MessageQueue.cpp | 27 #define LOG_TAG "MessageQueue" 30 #include "MessageQueue.h" 40 MessageQueue::MessageQueue() 73 MessageQueue::~MessageQueue() 99 android::status_t MessageQueue::get(Message* msg) 151 int MessageQueue::getInFd() 163 void MessageQueue::setInFd(int fd) 187 android::status_t MessageQueue::put(Message* msg [all...] |
Android.mk | 10 MessageQueue.cpp \
|
/frameworks/native/services/surfaceflinger/ |
MessageQueue.cpp | 30 #include "MessageQueue.h" 52 void MessageQueue::Handler::dispatchRefresh() { 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); 58 void MessageQueue::Handler::dispatchInvalidate() { 60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); 64 void MessageQueue::Handler::dispatchTransaction() { 66 mQueue.mLooper->sendMessage(this, Message(MessageQueue::TRANSACTION)); 70 void MessageQueue::Handler::handleMessage(const Message& message) { 89 MessageQueue::MessageQueue() [all...] |
MessageQueue.h | 62 class MessageQueue { 69 MessageQueue& mQueue; 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } 99 MessageQueue(); 100 ~MessageQueue();
|
/external/chromium_org/third_party/WebKit/Source/wtf/ |
MessageQueue.h | 49 // Essentially, MessageQueue acts as a queue of OwnPtr<DataType>. 51 class MessageQueue { 52 WTF_MAKE_NONCOPYABLE(MessageQueue); 54 MessageQueue() : m_killed(false) { } 55 ~MessageQueue(); 90 MessageQueue<DataType>::~MessageQueue() 96 inline bool MessageQueue<DataType>::append(PassOwnPtr<DataType> message) 105 inline void MessageQueue<DataType>::appendAndKill(PassOwnPtr<DataType> message) 115 inline bool MessageQueue<DataType>::appendAndCheckEmpty(PassOwnPtr<DataType> message [all...] |
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
pingtask.h | 32 #include "talk/base/messagequeue.h" 48 talk_base::MessageQueue* message_queue, uint32 ping_period_millis, 62 talk_base::MessageQueue* message_queue_;
|
/frameworks/base/core/tests/coretests/src/android/app/activity/ |
LocalActivity.java | 25 import android.os.MessageQueue;
|
LocalDialog.java | 25 import android.os.MessageQueue;
|
LocalScreen.java | 25 import android.os.MessageQueue;
|
TestedActivity.java | 23 import android.os.MessageQueue; 65 private class Idler implements MessageQueue.IdleHandler
|
/cts/tests/src/android/app/cts/ |
TestedActivity.java | 22 import android.os.MessageQueue; 52 private class Idler implements MessageQueue.IdleHandler {
|
/frameworks/base/core/java/android/view/ |
DisplayEventReceiver.java | 22 import android.os.MessageQueue; 43 private MessageQueue mMessageQueue; 46 MessageQueue messageQueue);
|
InputEventSender.java | 22 import android.os.MessageQueue; 41 private MessageQueue mMessageQueue; 44 InputChannel inputChannel, MessageQueue messageQueue);
|
/frameworks/base/core/java/android/os/ |
Looper.java | 60 final MessageQueue mQueue; 115 final MessageQueue queue = me.mQueue; 179 * Return the {@link MessageQueue} object associated with the current 183 public static MessageQueue myQueue() { 188 mQueue = new MessageQueue(quitAllowed); 286 public MessageQueue getQueue() {
|
/external/chromium_org/content/public/test/android/javatests/src/org/chromium/content/browser/test/ |
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/ |
webmessageportchannel_impl.h | 74 typedef std::queue<Message> MessageQueue; 75 MessageQueue message_queue_;
|