Delete method MessageQueue::set_socketserver

webrtc/p2p/base/relayport_unittest.cc

 /*
  *  Copyright 2009 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.
  */
 
@@ skipping 27 matching lines @@
 // (cricket::RelayServer) using all currently available protocols. The
 // network layer is faked out by using a VirtualSocketServer for
 // creating sockets. The test will monitor the current state of the
 // RelayPort and created sockets by listening for signals such as,
 // SignalConnectFailure, SignalConnectTimeout, SignalSocketClosed and
 // SignalReadPacket.
 class RelayPortTest : public testing::Test,
                       public sigslot::has_slots<> {
  public:
   RelayPortTest()
-      : main_(rtc::Thread::Current()),
-        physical_socket_server_(new rtc::PhysicalSocketServer),
+      : physical_socket_server_(new rtc::PhysicalSocketServer),
         virtual_socket_server_(new rtc::VirtualSocketServer(
             physical_socket_server_.get())),
-        ss_scope_(virtual_socket_server_.get()),
+        main_(virtual_socket_server_.get()),
         network_("unittest", "unittest", rtc::IPAddress(INADDR_ANY), 32),
         socket_factory_(rtc::Thread::Current()),
         username_(rtc::CreateRandomString(16)),
         password_(rtc::CreateRandomString(16)),
-        relay_port_(cricket::RelayPort::Create(main_, &socket_factory_,
+        relay_port_(cricket::RelayPort::Create(&main_, &socket_factory_,
                                                &network_,
                                                kLocalAddress.ipaddr(),
                                                0, 0, username_, password_)),
-        relay_server_(new cricket::RelayServer(main_)) {
+        relay_server_(new cricket::RelayServer(&main_)) {
   }
 
   void OnReadPacket(rtc::AsyncPacketSocket* socket,
                     const char* data, size_t size,
                     const rtc::SocketAddress& remote_addr,
                     const rtc::PacketTime& packet_time) {
     received_packet_count_[socket]++;
   }
 
   void OnConnectFailure(const cricket::ProtocolAddress* addr) {
@@ skipping 168 matching lines @@
       if (soft_timedout_connections_[i].address == addr->address &&
           soft_timedout_connections_[i].proto == addr->proto) {
         return true;
       }
     }
     return false;
   }
 
   typedef std::map<rtc::AsyncPacketSocket*, int> PacketMap;
 
-  rtc::Thread* main_;
   std::unique_ptr<rtc::PhysicalSocketServer> physical_socket_server_;
   std::unique_ptr<rtc::VirtualSocketServer> virtual_socket_server_;
-  rtc::SocketServerScope ss_scope_;
+  rtc::AutoSocketServerThread main_;
   rtc::Network network_;
   rtc::BasicPacketSocketFactory socket_factory_;
   std::string username_;
   std::string password_;
   std::unique_ptr<cricket::RelayPort> relay_port_;
   std::unique_ptr<cricket::RelayServer> relay_server_;
   std::vector<cricket::ProtocolAddress> failed_connections_;
   std::vector<cricket::ProtocolAddress> soft_timedout_connections_;
   PacketMap received_packet_count_;
 };
 
 TEST_F(RelayPortTest, ConnectUdp) {
   TestConnectUdp();
 }
 
 TEST_F(RelayPortTest, ConnectTcp) {
   TestConnectTcp();
 }
 
 TEST_F(RelayPortTest, ConnectSslTcp) {
   TestConnectSslTcp();
 }