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

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 985 matching lines @@
   rtc::scoped_ptr<IceMessage> msg;
   std::string remote_ufrag;
   const rtc::SocketAddress& addr(remote_candidate_.address());
   if (!port_->GetStunMessage(data, size, addr, msg.accept(), &remote_ufrag)) {
     // The packet did not parse as a valid STUN message
 
     // If this connection is readable, then pass along the packet.
     if (read_state_ == STATE_READABLE) {
       // readable means data from this address is acceptable
       // Send it on!
-
       last_data_received_ = rtc::Time();
       recv_rate_tracker_.Update(size);
       SignalReadPacket(this, data, size, packet_time);
 
       // If timed out sending writability checks, start up again
       if (!pruned_ && (write_state_ == STATE_WRITE_TIMEOUT)) {
         LOG(LS_WARNING) << "Received a data packet on a timed-out Connection. "
                         << "Resetting state to STATE_WRITE_INIT.";
         set_write_state(STATE_WRITE_INIT);
       }
@@ skipping 420 matching lines @@
   }
 }
 
 void Connection::OnMessage(rtc::Message *pmsg) {
   ASSERT(pmsg->message_id == MSG_DELETE);
   LOG_J(LS_INFO, this) << "Connection deleted due to read or write timeout";
   SignalDestroyed(this);
   delete this;
 }
 
+uint32 Connection::last_received() {
+  return std::max(last_data_received_,
+             std::max(last_ping_received_, last_ping_response_received_));
+}
+
 size_t Connection::recv_bytes_second() {
   return recv_rate_tracker_.units_second();
 }
 
 size_t Connection::recv_total_bytes() {
   return recv_rate_tracker_.total_units();
 }
 
 size_t Connection::sent_bytes_second() {
   return send_rate_tracker_.units_second();
@@ skipping 94 matching lines @@
     ASSERT(sent < 0);
     error_ = port_->GetError();
     sent_packets_discarded_++;
   } else {
     send_rate_tracker_.Update(sent);
   }
   return sent;
 }
 
 }  // namespace cricket