| /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_;
|
