| Index: webrtc/base/messagequeue.h
|
| diff --git a/webrtc/base/messagequeue.h b/webrtc/base/messagequeue.h
|
| index bf110376b58d7eb681fb93477d8ac02384c6365d..3a5226cd0a0129bb6c149b170922eef6123b3614 100644
|
| --- a/webrtc/base/messagequeue.h
|
| +++ b/webrtc/base/messagequeue.h
|
| @@ -37,7 +37,7 @@
|
|
|
| // MessageQueueManager does cleanup of of message queues
|
|
|
| -class MessageQueueManager {
|
| +class MessageQueueManager : public MessageHandler {
|
| public:
|
| static void Add(MessageQueue *message_queue);
|
| static void Remove(MessageQueue *message_queue);
|
| @@ -50,20 +50,21 @@
|
| static bool IsInitialized();
|
|
|
| // Mainly for testing purposes, for use with a simulated clock.
|
| - // Ensures that all message queues have processed delayed messages
|
| - // up until the current point in time.
|
| - static void ProcessAllMessageQueues();
|
| + // Posts a no-op event on all message queues so they will wake from the
|
| + // socket server select() and process messages again.
|
| + static void WakeAllMessageQueues();
|
|
|
| private:
|
| static MessageQueueManager* Instance();
|
|
|
| MessageQueueManager();
|
| - ~MessageQueueManager();
|
| + ~MessageQueueManager() override;
|
|
|
| void AddInternal(MessageQueue *message_queue);
|
| void RemoveInternal(MessageQueue *message_queue);
|
| void ClearInternal(MessageHandler *handler);
|
| - void ProcessAllMessageQueuesInternal();
|
| + void WakeAllMessageQueuesInternal();
|
| + void OnMessage(Message* pmsg) override;
|
|
|
| static MessageQueueManager* instance_;
|
| // This list contains all live MessageQueues.
|
|
|