Searched refs:MessageQueue (Results 1 – 19 of 19) sorted by relevance
55 void MessageQueueManager::Add(MessageQueue *message_queue) { in Add()58 void MessageQueueManager::AddInternal(MessageQueue *message_queue) { in AddInternal()69 void MessageQueueManager::Remove(MessageQueue *message_queue) { in Remove()75 void MessageQueueManager::RemoveInternal(MessageQueue *message_queue) { in RemoveInternal()86 std::vector<MessageQueue *>::iterator iter; in RemoveInternal()111 std::vector<MessageQueue *>::iterator iter; in ClearInternal()119 MessageQueue::MessageQueue(SocketServer* ss) in MessageQueue() function in rtc::MessageQueue135 MessageQueue::~MessageQueue() { in ~MessageQueue()147 void MessageQueue::set_socketserver(SocketServer* ss) { in set_socketserver()152 void MessageQueue::Quit() { in Quit()[all …]
34 class MessageQueue; variable40 static void Add(MessageQueue *message_queue);41 static void Remove(MessageQueue *message_queue);56 void AddInternal(MessageQueue *message_queue);57 void RemoveInternal(MessageQueue *message_queue);62 std::vector<MessageQueue *> message_queues_;166 class MessageQueue {170 explicit MessageQueue(SocketServer* ss = NULL);171 virtual ~MessageQueue();257 RTC_DISALLOW_COPY_AND_ASSIGN(MessageQueue);
22 class MessageQueueTest: public testing::Test, public MessageQueue {54 MessageQueue* q) { in DelayedPostsWithIdenticalTimesAreProcessedInFifoOrder()75 MessageQueue q; in TEST_F()78 MessageQueue q_nullss(&nullss); in TEST_F()
18 class MessageQueue; variable32 virtual void SetMessageQueue(MessageQueue* queue) {} in SetMessageQueue()
128 MessageQueue* queue() { return msg_queue_; } in queue()142 void SetMessageQueue(MessageQueue* queue) override;154 MessageQueue* msg_queue_;
93 explicit Win32SocketServer(MessageQueue* message_queue);107 virtual void SetMessageQueue(MessageQueue* queue);125 MessageQueue *message_queue_;
142 : MessageQueue(ss), in Thread()316 MessageQueue::Quit(); in Stop()456 MessageQueue::Clear(phandler, id, removed); in Clear()
100 void SetMessageQueue(MessageQueue* queue) override;227 MessageQueue* msg_queue_;
67 void SetMessageQueue(MessageQueue* queue) override;
95 class Thread : public MessageQueue {
716 Win32SocketServer::Win32SocketServer(MessageQueue* message_queue) in Win32SocketServer()756 void Win32SocketServer::SetMessageQueue(MessageQueue* queue) { in SetMessageQueue()
193 void FirewallSocketServer::SetMessageQueue(MessageQueue* queue) { in SetMessageQueue()
376 void NATSocketServer::SetMessageQueue(MessageQueue* queue) { in SetMessageQueue()
573 void VirtualSocketServer::SetMessageQueue(MessageQueue* msg_queue) { in SetMessageQueue()
31 rtc::MessageQueue* message_queue,46 rtc::MessageQueue* message_queue_;
20 rtc::MessageQueue* message_queue, in PingTask()
118 typedef de::ThreadSafeRingBuffer<Message> MessageQueue; typedef150 MessageQueue m_msgQueue;
4 import android.os.MessageQueue;95 MessageQueue queue = Looper.myQueue(); in Engine()273 private static class RefQueueIdleHandler implements MessageQueue.IdleHandler {
781 0x71072f28 android.os.Handler enqueueMessage (Landroid/os/MessageQueue;Landroid/os/Message;J)Z Hand…1463 0x710c4048 android.os.Looper myQueue ()Landroid/os/MessageQueue; Looper.java1464 0x710c4138 android.os.Looper getQueue ()Landroid/os/MessageQueue; Looper.java2179 0x7115b098 android.os.MessageQueue addIdleHandler (Landroid/os/MessageQueue$IdleHandler;)V MessageQ…2180 0x7115b0f8 android.os.MessageQueue enqueueMessage (Landroid/os/Message;J)Z MessageQueue.java2181 0x7115b128 android.os.MessageQueue enqueueSyncBarrier (J)I MessageQueue.java2182 0x7115b188 android.os.MessageQueue hasMessages (Landroid/os/Handler;ILjava/lang/Object;)Z MessageQu…2183 0x7115b218 android.os.MessageQueue next ()Landroid/os/Message; MessageQueue.java2184 0x7115b2a8 android.os.MessageQueue removeIdleHandler (Landroid/os/MessageQueue$IdleHandler;)V Messa…2185 0x7115b2d8 android.os.MessageQueue removeMessages (Landroid/os/Handler;ILjava/lang/Object;)V Messag…[all …]