Index: webrtc/p2p/base/p2ptransportchannel_unittest.cc |
diff --git a/webrtc/p2p/base/p2ptransportchannel_unittest.cc b/webrtc/p2p/base/p2ptransportchannel_unittest.cc |
index e9d4be60f1801987f9722dac81b65a555c127c65..29faac37288c3eef2d61232b48be1b472b9a4fcb 100644 |
--- a/webrtc/p2p/base/p2ptransportchannel_unittest.cc |
+++ b/webrtc/p2p/base/p2ptransportchannel_unittest.cc |
@@ -182,14 +182,13 @@ class P2PTransportChannelTestBase : public testing::Test, |
public sigslot::has_slots<> { |
public: |
P2PTransportChannelTestBase() |
- : main_(rtc::Thread::Current()), |
- pss_(new rtc::PhysicalSocketServer), |
+ : pss_(new rtc::PhysicalSocketServer), |
vss_(new rtc::VirtualSocketServer(pss_.get())), |
nss_(new rtc::NATSocketServer(vss_.get())), |
ss_(new rtc::FirewallSocketServer(nss_.get())), |
- ss_scope_(ss_.get()), |
- stun_server_(TestStunServer::Create(main_, kStunAddr)), |
- turn_server_(main_, kTurnUdpIntAddr, kTurnUdpExtAddr), |
+ main_(ss_.get()), |
+ stun_server_(TestStunServer::Create(&main_, kStunAddr)), |
+ turn_server_(&main_, kTurnUdpIntAddr, kTurnUdpExtAddr), |
socks_server1_(ss_.get(), |
kSocksProxyAddrs[0], |
ss_.get(), |
@@ -696,8 +695,8 @@ class P2PTransportChannelTestBase : public testing::Test, |
GetEndpoint(ch)->saved_candidates_.push_back( |
std::unique_ptr<CandidatesData>(new CandidatesData(ch, c))); |
} else { |
- main_->Post(RTC_FROM_HERE, this, MSG_ADD_CANDIDATES, |
- new CandidatesData(ch, c)); |
+ main_.Post(RTC_FROM_HERE, this, MSG_ADD_CANDIDATES, |
+ new CandidatesData(ch, c)); |
} |
} |
void OnSelectedCandidatePairChanged( |
@@ -726,7 +725,7 @@ class P2PTransportChannelTestBase : public testing::Test, |
const std::vector<Candidate>& candidates) { |
// Candidate removals are not paused. |
CandidatesData* candidates_data = new CandidatesData(ch, candidates); |
- main_->Post(RTC_FROM_HERE, this, MSG_REMOVE_CANDIDATES, candidates_data); |
+ main_.Post(RTC_FROM_HERE, this, MSG_REMOVE_CANDIDATES, candidates_data); |
} |
// Tcp candidate verification has to be done when they are generated. |
@@ -749,7 +748,7 @@ class P2PTransportChannelTestBase : public testing::Test, |
void ResumeCandidates(int endpoint) { |
Endpoint* ed = GetEndpoint(endpoint); |
for (auto& candidate : ed->saved_candidates_) { |
- main_->Post(RTC_FROM_HERE, this, MSG_ADD_CANDIDATES, candidate.release()); |
+ main_.Post(RTC_FROM_HERE, this, MSG_ADD_CANDIDATES, candidate.release()); |
} |
ed->saved_candidates_.clear(); |
ed->save_candidates_ = false; |
@@ -875,12 +874,11 @@ class P2PTransportChannelTestBase : public testing::Test, |
bool nominated() { return nominated_; } |
private: |
- rtc::Thread* main_; |
std::unique_ptr<rtc::PhysicalSocketServer> pss_; |
std::unique_ptr<rtc::VirtualSocketServer> vss_; |
std::unique_ptr<rtc::NATSocketServer> nss_; |
std::unique_ptr<rtc::FirewallSocketServer> ss_; |
- rtc::SocketServerScope ss_scope_; |
+ rtc::AutoSocketServerThread main_; |
std::unique_ptr<TestStunServer> stun_server_; |
TestTurnServer turn_server_; |
rtc::SocksProxyServer socks_server1_; |
@@ -2934,7 +2932,7 @@ class P2PTransportChannelPingTest : public testing::Test, |
P2PTransportChannelPingTest() |
: pss_(new rtc::PhysicalSocketServer), |
vss_(new rtc::VirtualSocketServer(pss_.get())), |
- ss_scope_(vss_.get()) {} |
+ thread_(vss_.get()) {} |
protected: |
void PrepareChannel(P2PTransportChannel* ch) { |
@@ -3084,7 +3082,7 @@ class P2PTransportChannelPingTest : public testing::Test, |
private: |
std::unique_ptr<rtc::PhysicalSocketServer> pss_; |
std::unique_ptr<rtc::VirtualSocketServer> vss_; |
- rtc::SocketServerScope ss_scope_; |
+ rtc::AutoSocketServerThread thread_; |
CandidatePairInterface* last_selected_candidate_pair_ = nullptr; |
int selected_candidate_pair_switches_ = 0; |
int last_sent_packet_id_ = -1; |