chromium/net/third_party/quiche/src/quiche/quic/test_tools/quic_stream_sequencer_buffer_peer.cc

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

#include "quiche/quic/test_tools/quic_stream_sequencer_buffer_peer.h"

#include <cstddef>
#include <limits>
#include <string>

#include "quiche/quic/platform/api/quic_flags.h"
#include "quiche/quic/platform/api/quic_logging.h"
#include "quiche/quic/platform/api/quic_test.h"
#include "quiche/quic/test_tools/quic_test_utils.h"

BufferBlock;

static const size_t kBlockSizeBytes = …;

namespace quic {
namespace test {

QuicStreamSequencerBufferPeer::QuicStreamSequencerBufferPeer(
    QuicStreamSequencerBuffer* buffer)
    : … { … }

// Read from this buffer_ into the given destination buffer_ up to the
// size of the destination. Returns the number of bytes read. Reading from
// an empty buffer_->returns 0.
size_t QuicStreamSequencerBufferPeer::Read(char* dest_buffer, size_t size) { … }

// If buffer is empty, the blocks_ array must be empty, which means all
// blocks are deallocated.
bool QuicStreamSequencerBufferPeer::CheckEmptyInvariants() { … }

bool QuicStreamSequencerBufferPeer::IsBlockArrayEmpty() { … }

bool QuicStreamSequencerBufferPeer::CheckInitialState() { … }

bool QuicStreamSequencerBufferPeer::CheckBufferInvariants() { … }

size_t QuicStreamSequencerBufferPeer::GetInBlockOffset(
    QuicStreamOffset offset) { … }

BufferBlock* QuicStreamSequencerBufferPeer::GetBlock(size_t index) { … }

int QuicStreamSequencerBufferPeer::IntervalSize() { … }

size_t QuicStreamSequencerBufferPeer::max_buffer_capacity() { … }

size_t QuicStreamSequencerBufferPeer::ReadableBytes() { … }

void QuicStreamSequencerBufferPeer::set_total_bytes_read(
    QuicStreamOffset total_bytes_read) { … }

void QuicStreamSequencerBufferPeer::AddBytesReceived(QuicStreamOffset offset,
                                                     QuicByteCount length) { … }

bool QuicStreamSequencerBufferPeer::IsBufferAllocated() { … }

size_t QuicStreamSequencerBufferPeer::max_blocks_count() { … }

size_t QuicStreamSequencerBufferPeer::current_blocks_count() { … }

const QuicIntervalSet<QuicStreamOffset>&
QuicStreamSequencerBufferPeer::bytes_received() { … }

}  // namespace test
}  // namespace quic