chromium/services/network/public/cpp/net_adapters.cc

// Copyright 2017 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "services/network/public/cpp/net_adapters.h"

#include <limits>

#include "base/check_op.h"
#include "base/containers/span.h"
#include "net/base/net_errors.h"
#include "services/network/public/cpp/features.h"

namespace network {

NetToMojoPendingBuffer::NetToMojoPendingBuffer(
    mojo::ScopedDataPipeProducerHandle handle,
    base::span<char> buffer)
    : … { … }

NetToMojoPendingBuffer::~NetToMojoPendingBuffer() { … }

MojoResult NetToMojoPendingBuffer::BeginWrite(
    mojo::ScopedDataPipeProducerHandle* handle,
    scoped_refptr<NetToMojoPendingBuffer>* pending) { … }

mojo::ScopedDataPipeProducerHandle NetToMojoPendingBuffer::Complete(
    uint32_t num_bytes) { … }

NetToMojoIOBuffer::NetToMojoIOBuffer(
    scoped_refptr<NetToMojoPendingBuffer> pending_buffer,
    int offset)
    : … { … }

NetToMojoIOBuffer::~NetToMojoIOBuffer() { … }

MojoToNetPendingBuffer::MojoToNetPendingBuffer(
    mojo::ScopedDataPipeConsumerHandle handle,
    base::span<const char> buffer)
    : … { … }

MojoToNetPendingBuffer::~MojoToNetPendingBuffer() = default;

// static
MojoResult MojoToNetPendingBuffer::BeginRead(
    mojo::ScopedDataPipeConsumerHandle* handle,
    scoped_refptr<MojoToNetPendingBuffer>* pending) { … }

void MojoToNetPendingBuffer::CompleteRead(uint32_t num_bytes) { … }

mojo::ScopedDataPipeConsumerHandle MojoToNetPendingBuffer::ReleaseHandle() { … }

bool MojoToNetPendingBuffer::IsComplete() const { … }

MojoToNetIOBuffer::MojoToNetIOBuffer(
    scoped_refptr<MojoToNetPendingBuffer> pending_buffer,
    int bytes_to_be_read)
    : … { … }

MojoToNetIOBuffer::~MojoToNetIOBuffer() { … }

}  // namespace network