Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(485)

Unified Diff: net/quic/quic_buffered_packet_store.h

Issue 2193073003: Move shared files in net/quic/ into net/quic/core/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: io_thread_unittest.cc Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/quic_blocked_writer_interface.h ('k') | net/quic/quic_buffered_packet_store.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « net/quic/quic_blocked_writer_interface.h ('k') | net/quic/quic_buffered_packet_store.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698