chromium/storage/browser/blob/mojo_blob_reader.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 "storage/browser/blob/mojo_blob_reader.h"

#include "base/functional/bind.h"
#include "base/task/sequenced_task_runner.h"
#include "base/trace_event/trace_event.h"
#include "net/base/io_buffer.h"
#include "services/network/public/cpp/net_adapters.h"
#include "storage/browser/blob/blob_data_handle.h"
#include "third_party/blink/public/common/blob/blob_utils.h"

namespace storage {

// static
void MojoBlobReader::Create(
    const BlobDataHandle* handle,
    const net::HttpByteRange& range,
    std::unique_ptr<Delegate> delegate,
    mojo::ScopedDataPipeProducerHandle response_body_stream) { … }

MojoBlobReader::MojoBlobReader(
    const BlobDataHandle* handle,
    const net::HttpByteRange& range,
    std::unique_ptr<Delegate> delegate,
    mojo::ScopedDataPipeProducerHandle response_body_stream)
    : … { … }

MojoBlobReader::~MojoBlobReader() { … }

void MojoBlobReader::Start() { … }

void MojoBlobReader::NotifyCompletedAndDeleteIfNeeded(int result) { … }

void MojoBlobReader::DidCalculateSize(int result) { … }

void MojoBlobReader::DidReadSideData(BlobReader::Status status) { … }

void MojoBlobReader::StartReading() { … }

void MojoBlobReader::ReadMore() { … }

void MojoBlobReader::DidRead(bool completed_synchronously, int num_bytes) { … }

void MojoBlobReader::OnResponseBodyStreamClosed(
    MojoResult result,
    const mojo::HandleSignalsState& state) { … }

void MojoBlobReader::OnResponseBodyStreamReady(
    MojoResult result,
    const mojo::HandleSignalsState& state) { … }

}  // namespace storage