Dampening connection switch.

webrtc/p2p/base/port.h

 /*
  *  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 550 matching lines @@
   // This signal will be fired if this connection is nominated by the
   // controlling side.
   sigslot::signal1<Connection*> SignalNominated;
 
   // Invoked when Connection receives STUN error response with 487 code.
   void HandleRoleConflictFromPeer();
 
   State state() const { return state_; }
 
   int num_pings_sent() const { return num_pings_sent_; }
+  void reset_num_pings_sent() { num_pings_sent_ = 0; }
 
   IceMode remote_ice_mode() const { return remote_ice_mode_; }
 
   uint32_t ComputeNetworkCost() const;
 
   // Update the ICE password and/or generation of the remote candidate if a
   // ufrag in |remote_ice_parameters| matches the candidate's ufrag, and the
   // candidate's password and/or ufrag has not been set.
   // |remote_ice_parameters| should be a list of known ICE parameters ordered
   // by generation.
   void MaybeSetRemoteIceCredentialsAndGeneration(const std::string& ice_ufrag,
                                                  const std::string& ice_pwd,
                                                  int generation);
 
   // If |remote_candidate_| is peer reflexive and is equivalent to
   // |new_candidate| except the type, update |remote_candidate_| to
   // |new_candidate|.
   void MaybeUpdatePeerReflexiveCandidate(const Candidate& new_candidate);
 
   // Returns the last received time of any data, stun request, or stun
   // response in milliseconds
   int64_t last_received() const;
+  // Returns the first received time of any packet since the last time the
+  // transport channel is weak.

[pthatcher1, 2016/07/13 21:17:22]

is weak => was weakly connected

[honghaiz3, 2016/07/14 04:54:20]

Method removed and replaced.

+  int64_t first_received_since_channel_weak() const {
+    return first_received_since_channel_weak_;
+  }
+
+  void reset_first_received_since_channel_weak() {
+    first_received_since_channel_weak_ = 0;
+  }
 
   bool stable(int64_t now) const;
 
  protected:
   enum { MSG_DELETE = 0, MSG_FIRST_AVAILABLE };
 
   // Constructs a new connection to the given remote port.
   Connection(Port* port, size_t index, const Candidate& candidate);
 
   // Called back when StunRequestManager has a stun packet to send
@@ skipping 38 matching lines @@
   bool nominated_;
   IceMode remote_ice_mode_;
   StunRequestManager requests_;
   int rtt_;
   int rtt_samples_ = 0;
   int64_t last_ping_sent_;      // last time we sent a ping to the other side
   int64_t last_ping_received_;  // last time we received a ping from the other
                                 // side
   int64_t last_data_received_;
   int64_t last_ping_response_received_;
+  int64_t first_received_since_channel_weak_ = 0;
   std::vector<SentPing> pings_since_last_response_;
 
   rtc::RateTracker recv_rate_tracker_;
   rtc::RateTracker send_rate_tracker_;
 
   ConnectionInfo stats_;
 
  private:
   void MaybeAddPrflxCandidate(ConnectionRequest* request,
                               StunMessage* response);
@@ skipping 19 matching lines @@
            const rtc::PacketOptions& options) override;
   int GetError() override { return error_; }
 
  private:
   int error_ = 0;
 };
 
 }  // namespace cricket
 
 #endif  // WEBRTC_P2P_BASE_PORT_H_