Index: net/quic/quic_buffered_packet_store.h |
diff --git a/net/quic/quic_buffered_packet_store.h b/net/quic/quic_buffered_packet_store.h |
deleted file mode 100644 |
index 67220fb3bdc5d4be5dc1a9ea173eafae436d7793..0000000000000000000000000000000000000000 |
--- a/net/quic/quic_buffered_packet_store.h |
+++ /dev/null |
@@ -1,124 +0,0 @@ |
-// 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" |
-#include "net/quic/quic_alarm_factory.h" |
-#include "net/quic/quic_clock.h" |
-#include "net/quic/quic_protocol.h" |
-#include "net/quic/quic_time.h" |
- |
-namespace net { |
- |
-namespace test { |
-class QuicBufferedPacketStorePeer; |
-} // namespace test |
- |
-// This class buffers undeliverable packets for each connection until either |
-// 1) They are requested to be delivered via DeliverPacket(), or |
-// 2) They expire after exceeding their lifetime in the store. |
-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<QuicReceivedPacket> packet, |
- IPEndPoint server_address, |
- IPEndPoint client_address); |
- BufferedPacket(BufferedPacket&& other); |
- |
- BufferedPacket& operator=(BufferedPacket&& other); |
- |
- ~BufferedPacket(); |
- |
- 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); |
- |
- ~BufferedPacketList(); |
- |
- std::list<BufferedPacket> buffered_packets; |
- QuicTime creation_time; |
- }; |
- |
- typedef linked_hash_map<QuicConnectionId, BufferedPacketList> |
- BufferedPacketMap; |
- |
- 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, |
- 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 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. |
- |
- 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_ |