Change QuicBufferedPacketStore to store QuicReceivedPackets instead of QuicEncrypterPackets, since …

net/quic/quic_buffered_packet_store.h

 // Copyright (c) 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef NET_QUIC_QUIC_BUFFERED_PACKET_STORE_H_
 #define NET_QUIC_QUIC_BUFFERED_PACKET_STORE_H_
 
 #include "net/base/ip_address.h"
 #include "net/base/linked_hash_map.h"
 #include "net/quic/quic_alarm.h"
@@ skipping 14 matching lines @@
 class NET_EXPORT_PRIVATE QuicBufferedPacketStore {
  public:
   enum EnqueuePacketResult {
     SUCCESS = 0,
     TOO_MANY_PACKETS,  // Too many packets stored up for a certain connection.
     TOO_MANY_CONNECTIONS  // Too many connections stored up in the store.
   };
 
   // A packets with client/server address.
   struct NET_EXPORT_PRIVATE BufferedPacket {
-    BufferedPacket(std::unique_ptr<QuicEncryptedPacket> packet,
+    BufferedPacket(std::unique_ptr<QuicReceivedPacket> packet,
                    IPEndPoint server_address,
                    IPEndPoint client_address);
     BufferedPacket(BufferedPacket&& other);
 
     BufferedPacket& operator=(BufferedPacket&& other);
 
     ~BufferedPacket();
 
-    std::unique_ptr<QuicEncryptedPacket> packet;
+    std::unique_ptr<QuicReceivedPacket> packet;
     IPEndPoint server_address;
     IPEndPoint client_address;
   };
 
   // A queue of BufferedPackets for a connection.
   struct NET_EXPORT_PRIVATE BufferedPacketList {
     BufferedPacketList();
     BufferedPacketList(BufferedPacketList&& other);
 
     BufferedPacketList& operator=(BufferedPacketList&& other);
@@ skipping 10 matching lines @@
   class NET_EXPORT_PRIVATE VisitorInterface {
    public:
     virtual ~VisitorInterface() {}
 
     // Called for each expired connection when alarm fires.
     virtual void OnExpiredPackets(QuicConnectionId connection_id,
                                   BufferedPacketList early_arrived_packets) = 0;
   };
 
   QuicBufferedPacketStore(VisitorInterface* vistor,
-                          QuicClock* clock,
+                          const QuicClock* clock,
                           QuicAlarmFactory* alarm_factory);
 
   QuicBufferedPacketStore(const QuicBufferedPacketStore&) = delete;
 
   ~QuicBufferedPacketStore();
 
   QuicBufferedPacketStore& operator=(const QuicBufferedPacketStore&) = delete;
 
   // Adds a copy of packet into packet queue for given connection.
   EnqueuePacketResult EnqueuePacket(QuicConnectionId connection_id,
-                                    const QuicEncryptedPacket& packet,
+                                    const QuicReceivedPacket& packet,
                                     IPEndPoint server_address,
                                     IPEndPoint client_address);
 
+  // Returns true if there are any packets buffered for |connection_id|.
+  bool HasBufferedPackets(QuicConnectionId connection_id) const;
+
   // Returns the list of buffered packets for |connection_id| and removes them
   // from the store. Returns an empty list if no early arrived packets for this
   // connection are present.
   std::list<BufferedPacket> DeliverPackets(QuicConnectionId connection_id);
 
   // Examines how long packets have been buffered in the store for each
   // connection. If they stay too long, removes them for new coming packets and
   // calls |visitor_|'s OnPotentialConnectionExpire().
   // Resets the alarm at the end.
   void OnExpirationTimeout();
 
  private:
   friend class test::QuicBufferedPacketStorePeer;
 
   // A map to store packet queues with creation time for each connection.
   BufferedPacketMap undecryptable_packets_;
 
   // The max time the packets of a connection can be buffer in the store.
   QuicTime::Delta connection_life_span_;
 
   VisitorInterface* visitor_;  // Unowned.
 
-  QuicClock* clock_;  // Unowned.
+  const QuicClock* clock_;  // Unowned.
 
   // This alarm fires every |connection_life_span_| to clean up
   // packets staying in the store for too long.
   std::unique_ptr<QuicAlarm> expiration_alarm_;
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUIC_BUFFERED_PACKET_STORE_H_