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