OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 29 matching lines...) Expand all Loading... |
40 using rtc::NAT_SYMMETRIC; | 40 using rtc::NAT_SYMMETRIC; |
41 using rtc::PacketSocketFactory; | 41 using rtc::PacketSocketFactory; |
42 using rtc::scoped_ptr; | 42 using rtc::scoped_ptr; |
43 using rtc::Socket; | 43 using rtc::Socket; |
44 using rtc::SocketAddress; | 44 using rtc::SocketAddress; |
45 using namespace cricket; | 45 using namespace cricket; |
46 | 46 |
47 static const int kTimeout = 1000; | 47 static const int kTimeout = 1000; |
48 static const SocketAddress kLocalAddr1("192.168.1.2", 0); | 48 static const SocketAddress kLocalAddr1("192.168.1.2", 0); |
49 static const SocketAddress kLocalAddr2("192.168.1.3", 0); | 49 static const SocketAddress kLocalAddr2("192.168.1.3", 0); |
50 static const SocketAddress kNatAddr1("77.77.77.77", rtc::NAT_SERVER_PORT); | 50 static const SocketAddress kNatAddr1("77.77.77.77", rtc::NAT_SERVER_UDP_PORT); |
51 static const SocketAddress kNatAddr2("88.88.88.88", rtc::NAT_SERVER_PORT); | 51 static const SocketAddress kNatAddr2("88.88.88.88", rtc::NAT_SERVER_UDP_PORT); |
52 static const SocketAddress kStunAddr("99.99.99.1", STUN_SERVER_PORT); | 52 static const SocketAddress kStunAddr("99.99.99.1", STUN_SERVER_PORT); |
53 static const SocketAddress kRelayUdpIntAddr("99.99.99.2", 5000); | 53 static const SocketAddress kRelayUdpIntAddr("99.99.99.2", 5000); |
54 static const SocketAddress kRelayUdpExtAddr("99.99.99.3", 5001); | 54 static const SocketAddress kRelayUdpExtAddr("99.99.99.3", 5001); |
55 static const SocketAddress kRelayTcpIntAddr("99.99.99.2", 5002); | 55 static const SocketAddress kRelayTcpIntAddr("99.99.99.2", 5002); |
56 static const SocketAddress kRelayTcpExtAddr("99.99.99.3", 5003); | 56 static const SocketAddress kRelayTcpExtAddr("99.99.99.3", 5003); |
57 static const SocketAddress kRelaySslTcpIntAddr("99.99.99.2", 5004); | 57 static const SocketAddress kRelaySslTcpIntAddr("99.99.99.2", 5004); |
58 static const SocketAddress kRelaySslTcpExtAddr("99.99.99.3", 5005); | 58 static const SocketAddress kRelaySslTcpExtAddr("99.99.99.3", 5005); |
59 static const SocketAddress kTurnUdpIntAddr("99.99.99.4", STUN_SERVER_PORT); | 59 static const SocketAddress kTurnUdpIntAddr("99.99.99.4", STUN_SERVER_PORT); |
60 static const SocketAddress kTurnUdpExtAddr("99.99.99.5", 0); | 60 static const SocketAddress kTurnUdpExtAddr("99.99.99.5", 0); |
61 static const RelayCredentials kRelayCredentials("test", "test"); | 61 static const RelayCredentials kRelayCredentials("test", "test"); |
(...skipping 274 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
336 | 336 |
337 class PortTest : public testing::Test, public sigslot::has_slots<> { | 337 class PortTest : public testing::Test, public sigslot::has_slots<> { |
338 public: | 338 public: |
339 PortTest() | 339 PortTest() |
340 : main_(rtc::Thread::Current()), | 340 : main_(rtc::Thread::Current()), |
341 pss_(new rtc::PhysicalSocketServer), | 341 pss_(new rtc::PhysicalSocketServer), |
342 ss_(new rtc::VirtualSocketServer(pss_.get())), | 342 ss_(new rtc::VirtualSocketServer(pss_.get())), |
343 ss_scope_(ss_.get()), | 343 ss_scope_(ss_.get()), |
344 network_("unittest", "unittest", rtc::IPAddress(INADDR_ANY), 32), | 344 network_("unittest", "unittest", rtc::IPAddress(INADDR_ANY), 32), |
345 socket_factory_(rtc::Thread::Current()), | 345 socket_factory_(rtc::Thread::Current()), |
346 nat_factory1_(ss_.get(), kNatAddr1), | 346 nat_factory1_(ss_.get(), kNatAddr1, SocketAddress()), |
347 nat_factory2_(ss_.get(), kNatAddr2), | 347 nat_factory2_(ss_.get(), kNatAddr2, SocketAddress()), |
348 nat_socket_factory1_(&nat_factory1_), | 348 nat_socket_factory1_(&nat_factory1_), |
349 nat_socket_factory2_(&nat_factory2_), | 349 nat_socket_factory2_(&nat_factory2_), |
350 stun_server_(TestStunServer::Create(main_, kStunAddr)), | 350 stun_server_(TestStunServer::Create(main_, kStunAddr)), |
351 turn_server_(main_, kTurnUdpIntAddr, kTurnUdpExtAddr), | 351 turn_server_(main_, kTurnUdpIntAddr, kTurnUdpExtAddr), |
352 relay_server_(main_, | 352 relay_server_(main_, |
353 kRelayUdpIntAddr, | 353 kRelayUdpIntAddr, |
354 kRelayUdpExtAddr, | 354 kRelayUdpExtAddr, |
355 kRelayTcpIntAddr, | 355 kRelayTcpIntAddr, |
356 kRelayTcpExtAddr, | 356 kRelayTcpExtAddr, |
357 kRelaySslTcpIntAddr, | 357 kRelaySslTcpIntAddr, |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
500 RelayPort* port = RelayPort::Create(main_, &socket_factory_, &network_, | 500 RelayPort* port = RelayPort::Create(main_, &socket_factory_, &network_, |
501 addr.ipaddr(), 0, 0, | 501 addr.ipaddr(), 0, 0, |
502 username_, password_); | 502 username_, password_); |
503 // TODO: Add an external address for ext_proto, so that the | 503 // TODO: Add an external address for ext_proto, so that the |
504 // other side can connect to this port using a non-UDP protocol. | 504 // other side can connect to this port using a non-UDP protocol. |
505 port->SetIceProtocolType(ice_protocol_); | 505 port->SetIceProtocolType(ice_protocol_); |
506 return port; | 506 return port; |
507 } | 507 } |
508 rtc::NATServer* CreateNatServer(const SocketAddress& addr, | 508 rtc::NATServer* CreateNatServer(const SocketAddress& addr, |
509 rtc::NATType type) { | 509 rtc::NATType type) { |
510 return new rtc::NATServer(type, ss_.get(), addr, ss_.get(), addr); | 510 return new rtc::NATServer(type, ss_.get(), addr, addr, ss_.get(), addr); |
511 } | 511 } |
512 static const char* StunName(NATType type) { | 512 static const char* StunName(NATType type) { |
513 switch (type) { | 513 switch (type) { |
514 case NAT_OPEN_CONE: return "stun(open cone)"; | 514 case NAT_OPEN_CONE: return "stun(open cone)"; |
515 case NAT_ADDR_RESTRICTED: return "stun(addr restricted)"; | 515 case NAT_ADDR_RESTRICTED: return "stun(addr restricted)"; |
516 case NAT_PORT_RESTRICTED: return "stun(port restricted)"; | 516 case NAT_PORT_RESTRICTED: return "stun(port restricted)"; |
517 case NAT_SYMMETRIC: return "stun(symmetric)"; | 517 case NAT_SYMMETRIC: return "stun(symmetric)"; |
518 default: return "stun(?)"; | 518 default: return "stun(?)"; |
519 } | 519 } |
520 } | 520 } |
(...skipping 2075 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2596 // Set up channels and ensure both ports will be deleted. | 2596 // Set up channels and ensure both ports will be deleted. |
2597 TestChannel ch1(port1, port2); | 2597 TestChannel ch1(port1, port2); |
2598 TestChannel ch2(port2, port1); | 2598 TestChannel ch2(port2, port1); |
2599 | 2599 |
2600 // Simulate a connection that succeeds, and then is destroyed. | 2600 // Simulate a connection that succeeds, and then is destroyed. |
2601 StartConnectAndStopChannels(&ch1, &ch2); | 2601 StartConnectAndStopChannels(&ch1, &ch2); |
2602 | 2602 |
2603 // The controlled port should be destroyed after 10 milliseconds. | 2603 // The controlled port should be destroyed after 10 milliseconds. |
2604 EXPECT_TRUE_WAIT(destroyed(), kTimeout); | 2604 EXPECT_TRUE_WAIT(destroyed(), kTimeout); |
2605 } | 2605 } |
OLD | NEW |