This source file includes following definitions.
- CreateForFileSystemFile
- ReadAdapter
- GetLengthAdapter
- Int64CallbackAdapter
- GetLength
- weak_factory_
- CreateSnapshot
- DidCreateSnapshot
#include "webkit/browser/fileapi/file_system_file_stream_reader.h"
#include "base/files/file_util_proxy.h"
#include "base/platform_file.h"
#include "base/single_thread_task_runner.h"
#include "net/base/file_stream.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "webkit/browser/blob/file_stream_reader.h"
#include "webkit/browser/fileapi/file_system_context.h"
#include "webkit/browser/fileapi/file_system_operation_runner.h"
using webkit_blob::FileStreamReader;
namespace webkit_blob {
FileStreamReader* FileStreamReader::CreateForFileSystemFile(
fileapi::FileSystemContext* file_system_context,
const fileapi::FileSystemURL& url,
int64 initial_offset,
const base::Time& expected_modification_time) {
return new fileapi::FileSystemFileStreamReader(
file_system_context,
url,
initial_offset,
expected_modification_time);
}
}
namespace fileapi {
namespace {
void ReadAdapter(base::WeakPtr<FileSystemFileStreamReader> reader,
net::IOBuffer* buf, int buf_len,
const net::CompletionCallback& callback) {
if (!reader.get())
return;
int rv = reader->Read(buf, buf_len, callback);
if (rv != net::ERR_IO_PENDING)
callback.Run(rv);
}
void GetLengthAdapter(base::WeakPtr<FileSystemFileStreamReader> reader,
const net::Int64CompletionCallback& callback) {
if (!reader.get())
return;
int rv = reader->GetLength(callback);
if (rv != net::ERR_IO_PENDING)
callback.Run(rv);
}
void Int64CallbackAdapter(const net::Int64CompletionCallback& callback,
int value) {
callback.Run(value);
}
}
FileSystemFileStreamReader::~FileSystemFileStreamReader() {
}
int FileSystemFileStreamReader::Read(
net::IOBuffer* buf, int buf_len,
const net::CompletionCallback& callback) {
if (local_file_reader_)
return local_file_reader_->Read(buf, buf_len, callback);
return CreateSnapshot(
base::Bind(&ReadAdapter, weak_factory_.GetWeakPtr(),
make_scoped_refptr(buf), buf_len, callback),
callback);
}
int64 FileSystemFileStreamReader::GetLength(
const net::Int64CompletionCallback& callback) {
if (local_file_reader_)
return local_file_reader_->GetLength(callback);
return CreateSnapshot(
base::Bind(&GetLengthAdapter, weak_factory_.GetWeakPtr(), callback),
base::Bind(&Int64CallbackAdapter, callback));
}
FileSystemFileStreamReader::FileSystemFileStreamReader(
FileSystemContext* file_system_context,
const FileSystemURL& url,
int64 initial_offset,
const base::Time& expected_modification_time)
: file_system_context_(file_system_context),
url_(url),
initial_offset_(initial_offset),
expected_modification_time_(expected_modification_time),
has_pending_create_snapshot_(false),
weak_factory_(this) {
}
int FileSystemFileStreamReader::CreateSnapshot(
const base::Closure& callback,
const net::CompletionCallback& error_callback) {
DCHECK(!has_pending_create_snapshot_);
has_pending_create_snapshot_ = true;
file_system_context_->operation_runner()->CreateSnapshotFile(
url_,
base::Bind(&FileSystemFileStreamReader::DidCreateSnapshot,
weak_factory_.GetWeakPtr(),
callback,
error_callback));
return net::ERR_IO_PENDING;
}
void FileSystemFileStreamReader::DidCreateSnapshot(
const base::Closure& callback,
const net::CompletionCallback& error_callback,
base::File::Error file_error,
const base::File::Info& file_info,
const base::FilePath& platform_path,
const scoped_refptr<webkit_blob::ShareableFileReference>& file_ref) {
DCHECK(has_pending_create_snapshot_);
DCHECK(!local_file_reader_.get());
has_pending_create_snapshot_ = false;
if (file_error != base::File::FILE_OK) {
error_callback.Run(net::FileErrorToNetError(file_error));
return;
}
snapshot_ref_ = file_ref;
local_file_reader_.reset(
FileStreamReader::CreateForLocalFile(
file_system_context_->default_file_task_runner(),
platform_path, initial_offset_, expected_modification_time_));
callback.Run();
}
}