Reland "Update includes for webrtc/{base => rtc_base} rename (3/3)"

webrtc/rtc_base/messagequeue_unittest.cc

 /*
  *  Copyright 2004 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
-#include "webrtc/base/messagequeue.h"
+#include "webrtc/rtc_base/messagequeue.h"
 
 #include <functional>
 
-#include "webrtc/base/atomicops.h"
-#include "webrtc/base/bind.h"
-#include "webrtc/base/event.h"
-#include "webrtc/base/gunit.h"
-#include "webrtc/base/logging.h"
-#include "webrtc/base/thread.h"
-#include "webrtc/base/timeutils.h"
-#include "webrtc/base/nullsocketserver.h"
+#include "webrtc/rtc_base/atomicops.h"
+#include "webrtc/rtc_base/bind.h"
+#include "webrtc/rtc_base/event.h"
+#include "webrtc/rtc_base/gunit.h"
+#include "webrtc/rtc_base/logging.h"
+#include "webrtc/rtc_base/nullsocketserver.h"
+#include "webrtc/rtc_base/thread.h"
+#include "webrtc/rtc_base/timeutils.h"
 
 using namespace rtc;
 
 class MessageQueueTest: public testing::Test, public MessageQueue {
  public:
   MessageQueueTest() : MessageQueue(SocketServer::CreateDefault(), true) {}
   bool IsLocked_Worker() {
     if (!crit_.TryEnter()) {
       return true;
     }
@@ skipping 175 matching lines @@
   FunctorMessageHandler<void, std::function<void()>> event_signaler(
       [&entered_process_all_message_queues] {
         entered_process_all_message_queues.Set();
       });
 
   // Post messages (both delayed and non delayed) to both threads.
   t.Post(RTC_FROM_HERE, &clearer);
   rtc::Thread::Current()->Post(RTC_FROM_HERE, &event_signaler);
   MessageQueueManager::ProcessAllMessageQueues();
 }