chromium/net/third_party/quiche/src/quiche/quic/core/uber_received_packet_manager.cc

// Copyright 2019 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.

#include "quiche/quic/core/uber_received_packet_manager.h"

#include <algorithm>

#include "quiche/quic/core/quic_types.h"
#include "quiche/quic/core/quic_utils.h"
#include "quiche/quic/platform/api/quic_bug_tracker.h"

namespace quic {

UberReceivedPacketManager::UberReceivedPacketManager(QuicConnectionStats* stats)
    : … { … }

UberReceivedPacketManager::~UberReceivedPacketManager() { … }

void UberReceivedPacketManager::SetFromConfig(const QuicConfig& config,
                                              Perspective perspective) { … }

bool UberReceivedPacketManager::IsAwaitingPacket(
    EncryptionLevel decrypted_packet_level,
    QuicPacketNumber packet_number) const { … }

const QuicFrame UberReceivedPacketManager::GetUpdatedAckFrame(
    PacketNumberSpace packet_number_space, QuicTime approximate_now) { … }

void UberReceivedPacketManager::RecordPacketReceived(
    EncryptionLevel decrypted_packet_level, const QuicPacketHeader& header,
    QuicTime receipt_time, QuicEcnCodepoint ecn_codepoint) { … }

void UberReceivedPacketManager::DontWaitForPacketsBefore(
    EncryptionLevel decrypted_packet_level, QuicPacketNumber least_unacked) { … }

void UberReceivedPacketManager::MaybeUpdateAckTimeout(
    bool should_last_packet_instigate_acks,
    EncryptionLevel decrypted_packet_level,
    QuicPacketNumber last_received_packet_number,
    QuicTime last_packet_receipt_time, QuicTime now,
    const RttStats* rtt_stats) { … }

void UberReceivedPacketManager::ResetAckStates(
    EncryptionLevel encryption_level) { … }

void UberReceivedPacketManager::EnableMultiplePacketNumberSpacesSupport(
    Perspective perspective) { … }

bool UberReceivedPacketManager::IsAckFrameUpdated() const { … }

QuicPacketNumber UberReceivedPacketManager::GetLargestObserved(
    EncryptionLevel decrypted_packet_level) const { … }

QuicTime UberReceivedPacketManager::GetAckTimeout(
    PacketNumberSpace packet_number_space) const { … }

QuicTime UberReceivedPacketManager::GetEarliestAckTimeout() const { … }

bool UberReceivedPacketManager::IsAckFrameEmpty(
    PacketNumberSpace packet_number_space) const { … }

size_t UberReceivedPacketManager::min_received_before_ack_decimation() const { … }

void UberReceivedPacketManager::set_min_received_before_ack_decimation(
    size_t new_value) { … }

void UberReceivedPacketManager::set_ack_frequency(size_t new_value) { … }

const QuicAckFrame& UberReceivedPacketManager::ack_frame() const { … }

const QuicAckFrame& UberReceivedPacketManager::GetAckFrame(
    PacketNumberSpace packet_number_space) const { … }

void UberReceivedPacketManager::set_max_ack_ranges(size_t max_ack_ranges) { … }

void UberReceivedPacketManager::set_save_timestamps(bool save_timestamps) { … }

void UberReceivedPacketManager::OnAckFrequencyFrame(
    const QuicAckFrequencyFrame& frame) { … }

}  // namespace quic