Start ICE connectivity checks as soon as the first pair is pingable.

webrtc/p2p/base/port.cc

 /*
  *  Copyright 2004 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 908 matching lines @@
     LOG_J(LS_VERBOSE, this) << "set_state";
   }
 }
 
 void Connection::set_connected(bool value) {
   bool old_value = connected_;
   connected_ = value;
   if (value != old_value) {
     LOG_J(LS_VERBOSE, this) << "set_connected from: " << old_value << " to "
                             << value;
+    SignalStateChange(this);
   }
 }
 
 void Connection::set_use_candidate_attr(bool enable) {
   use_candidate_attr_ = enable;
 }
 
 void Connection::OnSendStunPacket(const void* data, size_t size,
                                   StunRequest* req) {
   rtc::PacketOptions options(port_->DefaultDscpValue());
@@ skipping 289 matching lines @@
     return false;
   }
 
   // If it has never received anything and is not actively pinging (pruned), we
   // keep it around for at least MIN_CONNECTION_LIFETIME to prevent connections
   // from being pruned too quickly during a network change event when two
   // networks would be up simultaneously but only for a brief period.
   return now > (time_created_ms_ + MIN_CONNECTION_LIFETIME);
 }
 
-bool Connection::stable(int64_t now) {
+bool Connection::stable(int64_t now) const {
   // A connection is stable if it's RTT has converged and it isn't missing any
   // responses.  We should send pings at a higher rate until the RTT converges
   // and whenever a ping response is missing (so that we can detect
   // unwritability faster)
   return rtt_converged() && !missing_responses(now);
 }
 
 std::string Connection::ToDebugId() const {
   std::stringstream ss;
   ss << std::hex << this;
@@ skipping 251 matching lines @@
   new_local_candidate.set_network_cost(local_candidate().network_cost());
 
   // Change the local candidate of this Connection to the new prflx candidate.
   local_candidate_index_ = port_->AddPrflxCandidate(new_local_candidate);
 
   // SignalStateChange to force a re-sort in P2PTransportChannel as this
   // Connection's local candidate has changed.
   SignalStateChange(this);
 }
 
-bool Connection::rtt_converged() {
+bool Connection::rtt_converged() const {
   return rtt_samples_ > (RTT_RATIO + 1);
 }
 
-bool Connection::missing_responses(int64_t now) {
+bool Connection::missing_responses(int64_t now) const {
   if (pings_since_last_response_.empty()) {
     return false;
   }
 
   int64_t waiting = now - pings_since_last_response_[0].sent_time;
   return waiting > 2 * rtt();
 }
 
 ProxyConnection::ProxyConnection(Port* port,
                                  size_t index,
                                  const Candidate& remote_candidate)
     : Connection(port, index, remote_candidate) {}
 
 int ProxyConnection::Send(const void* data, size_t size,
                           const rtc::PacketOptions& options) {
   stats_.sent_total_packets++;
   int sent = port_->SendTo(data, size, remote_candidate_.address(),
                            options, true);
   if (sent <= 0) {
     ASSERT(sent < 0);
     error_ = port_->GetError();
     stats_.sent_discarded_packets++;
   } else {
     send_rate_tracker_.AddSamples(sent);
   }
   return sent;
 }
 
 }  // namespace cricket