Add flakiness check if there is no received packets in a certain period.

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 522 matching lines @@
   // Prints pings_since_last_response_ into a string.
   void PrintPingsSinceLastResponse(std::string* pings, size_t max);
 
   bool reported() const { return reported_; }
   void set_reported(bool reported) { reported_ = reported;}
 
   // This flag will be set if this connection is the chosen one for media
   // transmission. This connection will send STUN ping with USE-CANDIDATE
   // attribute.
   sigslot::signal1<Connection*> SignalUseCandidate;
+
   // Invoked when Connection receives STUN error response with 487 code.
   void HandleRoleConflictFromPeer();
 
   State state() const { return state_; }
 
   IceMode remote_ice_mode() const { return remote_ice_mode_; }
 
   // Update the ICE password of the remote candidate if |ice_ufrag| matches
   // the candidate's ufrag, and the candidate's passwrod has not been set.
   void MaybeSetRemoteIceCredentials(const std::string& ice_ufrag,
                                     const std::string& ice_pwd);
 
   // 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 true if there is any incoming (data/stun request/stun response)
+  // packet in the last |receiving_timeout| milliseconds.
+  bool CheckReceiving(uint32 receiving_timeout);

[pthatcher1, 2015/06/26 19:24:02]

I think it would be better to just have a last_received() method that returns
the max of the three values we store and let the caller  compare that with the
current time and timeout value.

[honghaiz3, 2015/08/05 23:56:56]

Done.

+
  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
   void OnSendStunPacket(const void* data, size_t size, StunRequest* req);
 
   // Callbacks from ConnectionRequest
@@ skipping 62 matching lines @@
                    const rtc::PacketOptions& options);
   virtual int GetError() { return error_; }
 
  private:
   int error_;
 };
 
 }  // namespace cricket
 
 #endif  // WEBRTC_P2P_BASE_PORT_H_