Index: webrtc/p2p/client/basicportallocator.cc |
diff --git a/webrtc/p2p/client/basicportallocator.cc b/webrtc/p2p/client/basicportallocator.cc |
index 1965ad94f73188dd57d0b5c6f01397cca5fa3944..8f2c4756bb89a682decf3ac9628d0006a2f813b7 100644 |
--- a/webrtc/p2p/client/basicportallocator.cc |
+++ b/webrtc/p2p/client/basicportallocator.cc |
@@ -121,7 +121,6 @@ class AllocationSequence : public rtc::MessageHandler, |
} |
void CreateUDPPorts(); |
void CreateTCPPorts(); |
- void CreateStunPorts(); |
void CreateRelayPorts(); |
void CreateGturnPort(const RelayServerConfig& config); |
void CreateTurnPort(const RelayServerConfig& config); |
@@ -754,25 +753,15 @@ AllocationSequence::AllocationSequence(BasicPortAllocatorSession* session, |
} |
bool AllocationSequence::Init() { |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET) && |
- !IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_UFRAG)) { |
- LOG(LS_ERROR) << "Shared socket option can't be set without " |
- << "shared ufrag."; |
- ASSERT(false); |
- return false; |
- } |
- |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET)) { |
- udp_socket_.reset(session_->socket_factory()->CreateUdpSocket( |
- rtc::SocketAddress(ip_, 0), session_->allocator()->min_port(), |
- session_->allocator()->max_port())); |
- if (udp_socket_) { |
- udp_socket_->SignalReadPacket.connect( |
- this, &AllocationSequence::OnReadPacket); |
- } |
- // Continuing if |udp_socket_| is NULL, as local TCP and RelayPort using TCP |
- // are next available options to setup a communication channel. |
+ udp_socket_.reset(session_->socket_factory()->CreateUdpSocket( |
+ rtc::SocketAddress(ip_, 0), session_->allocator()->min_port(), |
+ session_->allocator()->max_port())); |
+ if (udp_socket_) { |
+ udp_socket_->SignalReadPacket.connect( |
+ this, &AllocationSequence::OnReadPacket); |
} |
+ // Continuing if |udp_socket_| is NULL, as local TCP and RelayPort using TCP |
+ // are next available options to setup a communication channel. |
return true; |
} |
@@ -842,7 +831,6 @@ void AllocationSequence::OnMessage(rtc::Message* msg) { |
switch (phase_) { |
case PHASE_UDP: |
CreateUDPPorts(); |
- CreateStunPorts(); |
EnableProtocol(PROTO_UDP); |
break; |
@@ -902,36 +890,23 @@ void AllocationSequence::CreateUDPPorts() { |
// TODO(mallinath) - Remove UDPPort creating socket after shared socket |
// is enabled completely. |
UDPPort* port = NULL; |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET) && udp_socket_) { |
- port = UDPPort::Create(session_->network_thread(), |
- session_->socket_factory(), network_, |
- udp_socket_.get(), |
- session_->username(), session_->password(), |
- session_->allocator()->origin()); |
- } else { |
- port = UDPPort::Create(session_->network_thread(), |
- session_->socket_factory(), |
- network_, ip_, |
- session_->allocator()->min_port(), |
- session_->allocator()->max_port(), |
- session_->username(), session_->password(), |
- session_->allocator()->origin()); |
- } |
- |
+ port = UDPPort::Create(session_->network_thread(), |
+ session_->socket_factory(), network_, |
+ udp_socket_.get(), |
+ session_->username(), session_->password(), |
+ session_->allocator()->origin()); |
if (port) { |
// If shared socket is enabled, STUN candidate will be allocated by the |
// UDPPort. |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET)) { |
- udp_port_ = port; |
- port->SignalDestroyed.connect(this, &AllocationSequence::OnPortDestroyed); |
- |
- // If STUN is not disabled, setting stun server address to port. |
- if (!IsFlagSet(PORTALLOCATOR_DISABLE_STUN)) { |
- if (config_ && !config_->StunServers().empty()) { |
- LOG(LS_INFO) << "AllocationSequence: UDPPort will be handling the " |
- << "STUN candidate generation."; |
- port->set_server_addresses(config_->StunServers()); |
- } |
+ udp_port_ = port; |
+ port->SignalDestroyed.connect(this, &AllocationSequence::OnPortDestroyed); |
+ |
+ // If STUN is not disabled, setting stun server address to port. |
+ if (!IsFlagSet(PORTALLOCATOR_DISABLE_STUN)) { |
+ if (config_ && !config_->StunServers().empty()) { |
+ LOG(LS_INFO) << "AllocationSequence: UDPPort will be handling the " |
+ << "STUN candidate generation."; |
+ port->set_server_addresses(config_->StunServers()); |
} |
} |
@@ -959,37 +934,6 @@ void AllocationSequence::CreateTCPPorts() { |
} |
} |
-void AllocationSequence::CreateStunPorts() { |
- if (IsFlagSet(PORTALLOCATOR_DISABLE_STUN)) { |
- LOG(LS_VERBOSE) << "AllocationSequence: STUN ports disabled, skipping."; |
- return; |
- } |
- |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET)) { |
- return; |
- } |
- |
- if (!(config_ && !config_->StunServers().empty())) { |
- LOG(LS_WARNING) |
- << "AllocationSequence: No STUN server configured, skipping."; |
- return; |
- } |
- |
- StunPort* port = StunPort::Create(session_->network_thread(), |
- session_->socket_factory(), |
- network_, ip_, |
- session_->allocator()->min_port(), |
- session_->allocator()->max_port(), |
- session_->username(), session_->password(), |
- config_->StunServers(), |
- session_->allocator()->origin()); |
- if (port) { |
- session_->AddAllocatedPort(port, this, true); |
- // Since StunPort is not created using shared socket, |port| will not be |
- // added to the dequeue. |
- } |
-} |
- |
void AllocationSequence::CreateRelayPorts() { |
if (IsFlagSet(PORTALLOCATOR_DISABLE_RELAY)) { |
LOG(LS_VERBOSE) << "AllocationSequence: Relay ports disabled, skipping."; |
@@ -1058,8 +1002,7 @@ void AllocationSequence::CreateTurnPort(const RelayServerConfig& config) { |
// don't pass shared socket for ports which will create TCP sockets. |
// TODO(mallinath) - Enable shared socket mode for TURN ports. Disabled |
// due to webrtc bug https://code.google.com/p/webrtc/issues/detail?id=3537 |
- if (IsFlagSet(PORTALLOCATOR_ENABLE_SHARED_SOCKET) && |
- relay_port->proto == PROTO_UDP) { |
+ if (relay_port->proto == PROTO_UDP) { |
port = TurnPort::Create(session_->network_thread(), |
session_->socket_factory(), |
network_, udp_socket_.get(), |