Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(634)

Unified Diff: webrtc/p2p/base/p2ptransportchannel_unittest.cc

Issue 2380923002: Replace RelayPort with TurnPort in p2ptransportchannel tests.
Patch Set: Do not have TURN TCP port, which caused some tests flaky Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webrtc/p2p/base/p2ptransportchannel_unittest.cc
diff --git a/webrtc/p2p/base/p2ptransportchannel_unittest.cc b/webrtc/p2p/base/p2ptransportchannel_unittest.cc
index 51ff5fe92306768577857d112ffcca7a44f73450..d7ee87300d9ed5f9d886bb7a0c8190d2a2e9c080 100644
--- a/webrtc/p2p/base/p2ptransportchannel_unittest.cc
+++ b/webrtc/p2p/base/p2ptransportchannel_unittest.cc
@@ -76,15 +76,8 @@ static const SocketAddress kCascadedPrivateAddrs[2] =
{ SocketAddress("192.168.10.11", 0), SocketAddress("192.168.20.22", 0) };
// The address of the public STUN server.
static const SocketAddress kStunAddr("99.99.99.1", cricket::STUN_SERVER_PORT);
-// The addresses for the public relay server.
-static const SocketAddress kRelayUdpIntAddr("99.99.99.2", 5000);
-static const SocketAddress kRelayUdpExtAddr("99.99.99.3", 5001);
-static const SocketAddress kRelayTcpIntAddr("99.99.99.2", 5002);
-static const SocketAddress kRelayTcpExtAddr("99.99.99.3", 5003);
-static const SocketAddress kRelaySslTcpIntAddr("99.99.99.2", 5004);
-static const SocketAddress kRelaySslTcpExtAddr("99.99.99.3", 5005);
// The addresses for the public turn server.
-static const SocketAddress kTurnUdpIntAddr("99.99.99.4",
+static const SocketAddress kTurnUdpIntAddr("99.99.99.3",
cricket::STUN_SERVER_PORT);
static const SocketAddress kTurnTcpIntAddr("99.99.99.4",
cricket::STUN_SERVER_PORT + 1);
@@ -134,6 +127,28 @@ cricket::Candidate CreateUdpCandidate(const std::string& type,
return c;
}
+cricket::BasicPortAllocator* CreateBasicPortAllocator(
+ rtc::NetworkManager* network_manager,
+ const cricket::ServerAddresses& stun_servers,
+ const rtc::SocketAddress& turn_server_udp,
+ const rtc::SocketAddress& turn_server_tcp) {
+ cricket::RelayServerConfig turn_server(cricket::RELAY_TURN);
+ turn_server.credentials = kRelayCredentials;
+ if (!turn_server_udp.IsNil()) {
+ turn_server.ports.push_back(
+ cricket::ProtocolAddress(turn_server_udp, cricket::PROTO_UDP, false));
+ }
+ if (!turn_server_tcp.IsNil()) {
+ turn_server.ports.push_back(
+ cricket::ProtocolAddress(turn_server_tcp, cricket::PROTO_TCP, false));
+ }
+ std::vector<cricket::RelayServerConfig> turn_servers(1, turn_server);
+
+ cricket::BasicPortAllocator* allocator =
+ new cricket::BasicPortAllocator(network_manager);
+ allocator->SetConfiguration(stun_servers, turn_servers, 0, false);
+ return allocator;
+}
} // namespace
namespace cricket {
@@ -166,13 +181,6 @@ class P2PTransportChannelTestBase : public testing::Test,
ss_scope_(ss_.get()),
stun_server_(TestStunServer::Create(main_, kStunAddr)),
turn_server_(main_, kTurnUdpIntAddr, kTurnUdpExtAddr),
- relay_server_(main_,
- kRelayUdpIntAddr,
- kRelayUdpExtAddr,
- kRelayTcpIntAddr,
- kRelayTcpExtAddr,
- kRelaySslTcpIntAddr,
- kRelaySslTcpExtAddr),
socks_server1_(ss_.get(),
kSocksProxyAddrs[0],
ss_.get(),
@@ -187,12 +195,12 @@ class P2PTransportChannelTestBase : public testing::Test,
ServerAddresses stun_servers;
stun_servers.insert(kStunAddr);
- ep1_.allocator_.reset(new BasicPortAllocator(
- &ep1_.network_manager_, stun_servers, kRelayUdpIntAddr,
- kRelayTcpIntAddr, kRelaySslTcpIntAddr));
- ep2_.allocator_.reset(new BasicPortAllocator(
- &ep2_.network_manager_, stun_servers, kRelayUdpIntAddr,
- kRelayTcpIntAddr, kRelaySslTcpIntAddr));
+ ep1_.allocator_.reset(
+ CreateBasicPortAllocator(&ep1_.network_manager_, stun_servers,
+ kTurnUdpIntAddr, rtc::SocketAddress()));
+ ep2_.allocator_.reset(
+ CreateBasicPortAllocator(&ep2_.network_manager_, stun_servers,
+ kTurnUdpIntAddr, rtc::SocketAddress()));
}
protected:
@@ -844,7 +852,6 @@ class P2PTransportChannelTestBase : public testing::Test,
rtc::SocketServerScope ss_scope_;
std::unique_ptr<TestStunServer> stun_server_;
TestTurnServer turn_server_;
- TestRelayServer relay_server_;
rtc::SocksProxyServer socks_server1_;
rtc::SocksProxyServer socks_server2_;
Endpoint ep1_;
@@ -951,22 +958,6 @@ class P2PTransportChannelTest : public P2PTransportChannelTestBase {
Config config2,
int allocator_flags1,
int allocator_flags2) {
- ServerAddresses stun_servers;
- stun_servers.insert(kStunAddr);
- GetEndpoint(0)->allocator_.reset(new BasicPortAllocator(
- &(GetEndpoint(0)->network_manager_), stun_servers, rtc::SocketAddress(),
- rtc::SocketAddress(), rtc::SocketAddress()));
- GetEndpoint(1)->allocator_.reset(new BasicPortAllocator(
- &(GetEndpoint(1)->network_manager_), stun_servers, rtc::SocketAddress(),
- rtc::SocketAddress(), rtc::SocketAddress()));
-
- RelayServerConfig turn_server(RELAY_TURN);
- turn_server.credentials = kRelayCredentials;
- turn_server.ports.push_back(
- ProtocolAddress(kTurnUdpIntAddr, PROTO_UDP, false));
- GetEndpoint(0)->allocator_->AddTurnServer(turn_server);
- GetEndpoint(1)->allocator_->AddTurnServer(turn_server);
-
int delay = kMinimumStepDelay;
ConfigureEndpoint(0, config1);
SetAllocatorFlags(0, allocator_flags1);
@@ -3814,15 +3805,11 @@ class P2PTransportChannelMostLikelyToWorkFirstTest
P2PTransportChannelMostLikelyToWorkFirstTest()
: turn_server_(rtc::Thread::Current(), kTurnUdpIntAddr, kTurnUdpExtAddr) {
network_manager_.AddInterface(kPublicAddrs[0]);
- allocator_.reset(new BasicPortAllocator(
- &network_manager_, ServerAddresses(), rtc::SocketAddress(),
- rtc::SocketAddress(), rtc::SocketAddress()));
+ allocator_.reset(
+ CreateBasicPortAllocator(&network_manager_, ServerAddresses(),
+ kTurnUdpIntAddr, rtc::SocketAddress()));
allocator_->set_flags(allocator_->flags() | PORTALLOCATOR_DISABLE_STUN |
PORTALLOCATOR_DISABLE_TCP);
- RelayServerConfig config(RELAY_TURN);
- config.credentials = kRelayCredentials;
- config.ports.push_back(ProtocolAddress(kTurnUdpIntAddr, PROTO_UDP, false));
- allocator_->AddTurnServer(config);
allocator_->set_step_delay(kMinimumStepDelay);
}
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698