| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| message_queue.cc | 13 MessageQueue::MessageQueue() {
16 MessageQueue::~MessageQueue() {
21 bool MessageQueue::IsEmpty() const {
25 void MessageQueue::Push(Message* message) {
30 void MessageQueue::Pop(Message* message) {
36 void MessageQueue::Pop() {
|
| message_queue.h | 18 class MessageQueue {
20 MessageQueue();
21 ~MessageQueue();
39 DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| router_test_util.h | 18 class MessageQueue;
28 MessageAccumulator(MessageQueue* queue,
35 MessageQueue* queue_;
|
| /external/webrtc/webrtc/base/ |
| socketserver.h | 18 class MessageQueue;
32 virtual void SetMessageQueue(MessageQueue* queue) {}
|
| messagequeue.cc | 19 #include "webrtc/base/messagequeue.h"
55 void MessageQueueManager::Add(MessageQueue *message_queue) {
58 void MessageQueueManager::AddInternal(MessageQueue *message_queue) {
69 void MessageQueueManager::Remove(MessageQueue *message_queue) {
75 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) {
79 // If this is the last MessageQueue, destroy the manager as well so that
86 std::vector<MessageQueue *>::iterator iter;
111 std::vector<MessageQueue *>::iterator iter;
117 // MessageQueue
119 MessageQueue::MessageQueue(SocketServer* ss
[all...] |
| /hardware/qcom/data/ipacfg-mgr/msm8998/ipacm/src/ |
| IPACM_CmdQueue.cpp | 48 MessageQueue* MessageQueue::inst_internal = NULL;
49 MessageQueue* MessageQueue::inst_external = NULL;
51 MessageQueue* MessageQueue::getInstanceInternal()
55 inst_internal = new MessageQueue();
66 MessageQueue* MessageQueue::getInstanceExternal()
70 inst_external = new MessageQueue();
[all...] |
| /frameworks/base/core/jni/ |
| android_os_MessageQueue.h | 25 class MessageQueue : public virtual RefBase {
58 MessageQueue();
59 virtual ~MessageQueue();
65 /* Gets the native object associated with a MessageQueue. */
66 extern sp<MessageQueue> android_os_MessageQueue_getMessageQueue(
|
| /frameworks/native/services/surfaceflinger/ |
| MessageQueue.cpp | 29 #include "MessageQueue.h"
51 void MessageQueue::Handler::dispatchRefresh() {
53 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH));
57 void MessageQueue::Handler::dispatchInvalidate() {
59 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE));
63 void MessageQueue::Handler::handleMessage(const Message& message) {
78 MessageQueue::MessageQueue()
82 MessageQueue::~MessageQueue() {
[all...] |
| MessageQueue.h | 80 class MessageQueue {
87 MessageQueue& mQueue;
90 explicit Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
115 MessageQueue();
116 ~MessageQueue();
|
| /external/libmojo/mojo/edk/system/ports/ |
| message_queue.cc | 25 MessageQueue::MessageQueue() : MessageQueue(kInitialSequenceNum) {}
27 MessageQueue::MessageQueue(uint64_t next_sequence_num)
33 MessageQueue::~MessageQueue() {
43 bool MessageQueue::HasNextMessage() const {
47 void MessageQueue::GetNextMessageIf(
62 void MessageQueue::AcceptMessage(ScopedMessage message
[all...] |
| message_queue.h | 25 // An incoming message queue for a port. MessageQueue keeps track of the highest
29 class MessageQueue {
31 explicit MessageQueue();
32 explicit MessageQueue(uint64_t next_sequence_num);
33 ~MessageQueue();
64 DISALLOW_COPY_AND_ASSIGN(MessageQueue);
|
| /hardware/qcom/data/ipacfg-mgr/msm8998/ipacm/inc/ |
| IPACM_CmdQueue.h | 81 class MessageQueue
88 static MessageQueue *inst_internal;
89 static MessageQueue *inst_external;
91 MessageQueue()
99 ~MessageQueue() { }
103 static MessageQueue* getInstanceInternal();
104 static MessageQueue* getInstanceExternal();
|
| /hardware/interfaces/tests/msgq/1.0/default/ |
| BenchmarkMsgQ.h | 23 #include <fmq/MessageQueue.h>
72 static void QueueWriter(android::hardware::MessageQueue<uint8_t, flavor>*
81 android::hardware::MessageQueue<uint8_t, flavor>* mFmqInbox,
82 android::hardware::MessageQueue<uint8_t, flavor>* mFmqOutbox,
86 android::hardware::MessageQueue<uint8_t, kSynchronizedReadWrite>* mFmqInbox;
87 android::hardware::MessageQueue<uint8_t, kSynchronizedReadWrite>* mFmqOutbox;
|
| TestMsgQ.h | 23 #include <fmq/MessageQueue.h>
49 using android::hardware::MessageQueue;
52 typedef MessageQueue<uint16_t, kSynchronizedReadWrite> MessageQueueSync;
53 typedef MessageQueue<uint16_t, kUnsynchronizedWrite> MessageQueueUnsync;
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| pingtask.h | 16 #include "webrtc/base/messagequeue.h"
31 rtc::MessageQueue* message_queue,
46 rtc::MessageQueue* message_queue_;
|
| /frameworks/base/core/java/android/hardware/camera2/legacy/ |
| RequestHandlerThread.java | 23 import android.os.MessageQueue;
28 * Ensure that the MessageQueue's idle handler gets run by poking the message queue;
88 private final MessageQueue.IdleHandler mIdleHandler = new MessageQueue.IdleHandler() {
99 MessageQueue queue = handler.getLooper().getQueue();
|
| /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/app/app/src/android/app/stubs/ |
| TestedActivity.java | 22 import android.os.MessageQueue;
52 private class Idler implements MessageQueue.IdleHandler {
|
| /frameworks/base/core/java/android/view/ |
| FrameMetricsObserver.java | 21 import android.os.MessageQueue;
34 private MessageQueue mMessageQueue;
|
| DisplayEventReceiver.java | 20 import android.os.MessageQueue;
63 private MessageQueue mMessageQueue;
66 MessageQueue messageQueue, int vsyncSource);
|
| /packages/apps/Launcher3/src/com/android/launcher3/util/ |
| LooperIdleLock.java | 20 import android.os.MessageQueue;
27 public class LooperIdleLock implements MessageQueue.IdleHandler, Runnable {
|
| /system/libfmq/include/fmq/ |
| MessageQueue.h | 38 struct MessageQueue {
46 MessageQueue(const Descriptor& Desc, bool resetPointers = true);
48 ~MessageQueue();
54 * @param numElementsInQueue Capacity of the MessageQueue in terms of T.
58 MessageQueue(size_t numElementsInQueue, bool configureEventFlagWord = false);
223 * word will be unmapped by the MessageQueue destructor.
418 MessageQueue(const MessageQueue& other) = delete;
419 MessageQueue& operator=(const MessageQueue& other) = delete
[all...] |
