chromium/third_party/blink/renderer/core/fetch/bytes_uploader.cc

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

#include "third_party/blink/renderer/core/fetch/bytes_uploader.h"

#include "base/compiler_specific.h"
#include "base/containers/span.h"
#include "base/numerics/checked_math.h"
#include "base/numerics/safe_conversions.h"
#include "base/task/single_thread_task_runner.h"
#include "net/base/net_errors.h"
#include "third_party/blink/public/platform/task_type.h"
#include "third_party/blink/renderer/core/execution_context/execution_context.h"
#include "third_party/blink/renderer/platform/heap/persistent.h"
#include "third_party/blink/renderer/platform/loader/fetch/bytes_consumer.h"
#include "third_party/blink/renderer/platform/wtf/functional.h"

namespace blink {

BytesUploader::BytesUploader(
    ExecutionContext* execution_context,
    BytesConsumer* consumer,
    mojo::PendingReceiver<network::mojom::blink::ChunkedDataPipeGetter>
        pending_receiver,
    scoped_refptr<base::SingleThreadTaskRunner> task_runner,
    Client* client)
    : … { … }

BytesUploader::~BytesUploader() = default;

void BytesUploader::Trace(blink::Visitor* visitor) const { … }

void BytesUploader::GetSize(GetSizeCallback get_size_callback) { … }

void BytesUploader::StartReading(
    mojo::ScopedDataPipeProducerHandle upload_pipe) { … }

void BytesUploader::ContextDestroyed() { … }

void BytesUploader::OnStateChange() { … }

void BytesUploader::OnPipeWriteable(MojoResult unused) { … }

void BytesUploader::WriteDataOnPipe() { … }

void BytesUploader::Close() { … }

void BytesUploader::CloseOnError() { … }

void BytesUploader::Dispose() { … }

}  // namespace blink