chromium/storage/browser/file_system/local_file_stream_writer.cc

// Copyright 2012 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/file_system/local_file_stream_writer.h"

#include <stdint.h>

#include <memory>

#include "base/functional/bind.h"
#include "base/types/pass_key.h"
#include "net/base/file_stream.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"

namespace storage {

namespace {

const int kOpenFlagsForWrite = …;
const int kCreateFlagsForWrite = …;
const int kCreateFlagsForWriteAlways = …;
#if BUILDFLAG(IS_ANDROID)
// Android always opens Content-URI files for write with truncate for security.
const int kOpenFlagsForWriteContentUri = base::File::FLAG_CREATE_ALWAYS |
                                         base::File::FLAG_WRITE |
                                         base::File::FLAG_ASYNC;
#endif

}  // namespace

std::unique_ptr<FileStreamWriter> FileStreamWriter::CreateForLocalFile(
    base::TaskRunner* task_runner,
    const base::FilePath& file_path,
    int64_t initial_offset,
    OpenOrCreate open_or_create) { … }

LocalFileStreamWriter::~LocalFileStreamWriter() { … }

int LocalFileStreamWriter::Write(net::IOBuffer* buf,
                                 int buf_len,
                                 net::CompletionOnceCallback callback) { … }

int LocalFileStreamWriter::Cancel(net::CompletionOnceCallback callback) { … }

int LocalFileStreamWriter::Flush(FlushMode /*flush_mode*/,
                                 net::CompletionOnceCallback callback) { … }

LocalFileStreamWriter::LocalFileStreamWriter(
    base::TaskRunner* task_runner,
    const base::FilePath& file_path,
    int64_t initial_offset,
    OpenOrCreate open_or_create,
    base::PassKey<FileStreamWriter> /*pass_key*/)
    : … { … }

int LocalFileStreamWriter::InitiateOpen(base::OnceClosure main_operation) { … }

void LocalFileStreamWriter::DidOpen(base::OnceClosure main_operation,
                                    int result) { … }

void LocalFileStreamWriter::InitiateSeek(base::OnceClosure main_operation) { … }

void LocalFileStreamWriter::DidSeek(base::OnceClosure main_operation,
                                    int64_t result) { … }

void LocalFileStreamWriter::ReadyToWrite(net::IOBuffer* buf, int buf_len) { … }

int LocalFileStreamWriter::InitiateWrite(net::IOBuffer* buf, int buf_len) { … }

void LocalFileStreamWriter::DidWrite(int result) { … }

int LocalFileStreamWriter::InitiateFlush(net::CompletionOnceCallback callback) { … }

void LocalFileStreamWriter::DidFlush(net::CompletionOnceCallback callback,
                                     int result) { … }

bool LocalFileStreamWriter::CancelIfRequested() { … }

}  // namespace storage