chromium/services/network/chunked_data_pipe_upload_data_stream.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.

#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/351564777): Remove this and convert code to safer constructs.
#pragma allow_unsafe_buffers
#endif

#include "services/network/chunked_data_pipe_upload_data_stream.h"

#include "base/check_op.h"
#include "base/containers/span.h"
#include "base/functional/bind.h"
#include "base/functional/callback.h"
#include "base/location.h"
#include "base/numerics/safe_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "mojo/public/c/system/types.h"
#include "net/base/io_buffer.h"

namespace network {

ChunkedDataPipeUploadDataStream::ChunkedDataPipeUploadDataStream(
    scoped_refptr<ResourceRequestBody> resource_request_body,
    mojo::PendingRemote<mojom::ChunkedDataPipeGetter> chunked_data_pipe_getter,
    bool has_null_source)
    : … { … }

ChunkedDataPipeUploadDataStream::~ChunkedDataPipeUploadDataStream() { … }

bool ChunkedDataPipeUploadDataStream::AllowHTTP1() const { … }

int ChunkedDataPipeUploadDataStream::InitInternal(
    const net::NetLogWithSource& net_log) { … }

int ChunkedDataPipeUploadDataStream::ReadInternal(net::IOBuffer* buf,
                                                  int buf_len) { … }

void ChunkedDataPipeUploadDataStream::ResetInternal() { … }

void ChunkedDataPipeUploadDataStream::OnSizeReceived(int32_t status,
                                                     uint64_t size) { … }

void ChunkedDataPipeUploadDataStream::OnHandleReadable(MojoResult result) { … }

void ChunkedDataPipeUploadDataStream::OnDataPipeGetterClosed() { … }

void ChunkedDataPipeUploadDataStream::EnableCache(size_t dst_window_size) { … }

void ChunkedDataPipeUploadDataStream::WriteToCacheIfNeeded(net::IOBuffer* buf,
                                                           size_t num_bytes) { … }

int ChunkedDataPipeUploadDataStream::ReadFromCacheIfNeeded(net::IOBuffer* buf,
                                                           int buf_len) { … }

}  // namespace network