diff options
author | kinuko@chromium.org <kinuko@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2012-03-06 03:45:10 +0000 |
---|---|---|
committer | kinuko@chromium.org <kinuko@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2012-03-06 03:45:10 +0000 |
commit | eb6182b422cd255d97c482ba04452ca624910573 (patch) | |
tree | 03739a41ce380962bec69300e39db6bc43a15b6c /webkit/blob | |
parent | 84f3b09d3af73a74b5fb80a5ad9d6a203255aafb (diff) | |
download | chromium_src-eb6182b422cd255d97c482ba04452ca624910573.zip chromium_src-eb6182b422cd255d97c482ba04452ca624910573.tar.gz chromium_src-eb6182b422cd255d97c482ba04452ca624910573.tar.bz2 |
Cleanup: rename some methods in BlobURLRequestJob for better readability
- ReadBytes -> ReadBytesItem
- DispatchReadFile -> ReadFileItem
- DidOpen -> DidOpenFile
- ReadFile -> ReadFileStream
- DidRead -> DidReadFileStream
- CloseStream -> CloseFileStream
- ReadCompleted -> BytesReadCompleted
BUG=114999
TEST=existing tests should pass
Review URL: https://chromiumcodereview.appspot.com/9600032
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@125097 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'webkit/blob')
-rw-r--r-- | webkit/blob/blob_url_request_job.cc | 42 | ||||
-rw-r--r-- | webkit/blob/blob_url_request_job.h | 18 |
2 files changed, 30 insertions, 30 deletions
diff --git a/webkit/blob/blob_url_request_job.cc b/webkit/blob/blob_url_request_job.cc index 1f44cba..bd4f191 100644 --- a/webkit/blob/blob_url_request_job.cc +++ b/webkit/blob/blob_url_request_job.cc @@ -73,7 +73,7 @@ BlobURLRequestJob::BlobURLRequestJob( BlobURLRequestJob::~BlobURLRequestJob() { // FileStream's destructor won't close it for us because we passed in our own // file handle. - CloseStream(); + CloseFileStream(); } void BlobURLRequestJob::Start() { @@ -84,7 +84,7 @@ void BlobURLRequestJob::Start() { } void BlobURLRequestJob::Kill() { - CloseStream(); + CloseFileStream(); net::URLRequestJob::Kill(); weak_factory_.InvalidateWeakPtrs(); @@ -296,9 +296,9 @@ bool BlobURLRequestJob::ReadItem() { const BlobData::Item& item = blob_data_->items().at(item_index_); switch (item.type) { case BlobData::TYPE_DATA: - return ReadBytes(item); + return ReadBytesItem(item); case BlobData::TYPE_FILE: - return DispatchReadFile(item); + return ReadFileItem(item); default: DCHECK(false); return false; @@ -307,7 +307,7 @@ bool BlobURLRequestJob::ReadItem() { void BlobURLRequestJob::AdvanceItem() { // Close the stream if the current item is a file. - CloseStream(); + CloseFileStream(); // Advance to the next item. item_index_++; @@ -331,7 +331,7 @@ void BlobURLRequestJob::AdvanceBytesRead(int result) { DCHECK_GE(read_buf_->BytesRemaining(), 0); } -bool BlobURLRequestJob::ReadBytes(const BlobData::Item& item) { +bool BlobURLRequestJob::ReadBytesItem(const BlobData::Item& item) { DCHECK_GE(read_buf_->BytesRemaining(), bytes_to_read_); memcpy(read_buf_->data(), @@ -342,22 +342,22 @@ bool BlobURLRequestJob::ReadBytes(const BlobData::Item& item) { return true; } -bool BlobURLRequestJob::DispatchReadFile(const BlobData::Item& item) { +bool BlobURLRequestJob::ReadFileItem(const BlobData::Item& item) { // If the stream already exists, keep reading from it. if (stream_ != NULL) - return ReadFile(); + return ReadFileStream(); base::FileUtilProxy::CreateOrOpen( file_thread_proxy_, item.file_path, kFileOpenFlags, - base::Bind(&BlobURLRequestJob::DidOpen, + base::Bind(&BlobURLRequestJob::DidOpenFile, weak_factory_.GetWeakPtr())); SetStatus(net::URLRequestStatus(net::URLRequestStatus::IO_PENDING, 0)); return false; } -void BlobURLRequestJob::DidOpen(base::PlatformFileError rv, - base::PassPlatformFile file, - bool created) { +void BlobURLRequestJob::DidOpenFile(base::PlatformFileError rv, + base::PassPlatformFile file, + bool created) { if (rv != base::PLATFORM_FILE_OK) { NotifyFailure(net::ERR_FAILED); return; @@ -377,10 +377,10 @@ void BlobURLRequestJob::DidOpen(base::PlatformFileError rv, } } - ReadFile(); + ReadFileStream(); } -bool BlobURLRequestJob::ReadFile() { +bool BlobURLRequestJob::ReadFileStream() { DCHECK(stream_.get()); DCHECK(stream_->IsOpen()); DCHECK_GE(read_buf_->BytesRemaining(), bytes_to_read_); @@ -388,7 +388,7 @@ bool BlobURLRequestJob::ReadFile() { // Start the asynchronous reading. int rv = stream_->Read(read_buf_, bytes_to_read_, - base::Bind(&BlobURLRequestJob::DidRead, + base::Bind(&BlobURLRequestJob::DidReadFileStream, base::Unretained(this))); // If I/O pending error is returned, we just need to wait. @@ -405,14 +405,14 @@ bool BlobURLRequestJob::ReadFile() { // Otherwise, data is immediately available. if (GetStatus().is_io_pending()) - DidRead(rv); + DidReadFileStream(rv); else AdvanceBytesRead(rv); return true; } -void BlobURLRequestJob::DidRead(int result) { +void BlobURLRequestJob::DidReadFileStream(int result) { if (result < 0) { NotifyFailure(net::ERR_FAILED); return; @@ -423,7 +423,7 @@ void BlobURLRequestJob::DidRead(int result) { // If the read buffer is completely filled, we're done. if (!read_buf_->BytesRemaining()) { - int bytes_read = ReadCompleted(); + int bytes_read = BytesReadCompleted(); NotifyReadComplete(bytes_read); return; } @@ -434,7 +434,7 @@ void BlobURLRequestJob::DidRead(int result) { NotifyReadComplete(bytes_read); } -void BlobURLRequestJob::CloseStream() { +void BlobURLRequestJob::CloseFileStream() { if (stream_ != NULL) { // stream_.Close() blocks the IO thread, see http://crbug.com/75548. base::ThreadRestrictions::ScopedAllowIO allow_io; @@ -443,7 +443,7 @@ void BlobURLRequestJob::CloseStream() { } } -int BlobURLRequestJob::ReadCompleted() { +int BlobURLRequestJob::BytesReadCompleted() { int bytes_read = read_buf_->BytesConsumed(); read_buf_ = NULL; return bytes_read; @@ -468,7 +468,7 @@ bool BlobURLRequestJob::ReadLoop(int* bytes_read) { return false; } - *bytes_read = ReadCompleted(); + *bytes_read = BytesReadCompleted(); return true; } diff --git a/webkit/blob/blob_url_request_job.h b/webkit/blob/blob_url_request_job.h index 26067fd..dbbf172 100644 --- a/webkit/blob/blob_url_request_job.h +++ b/webkit/blob/blob_url_request_job.h @@ -60,18 +60,18 @@ class BLOB_EXPORT BlobURLRequestJob : public net::URLRequestJob { bool ReadItem(); void AdvanceItem(); void AdvanceBytesRead(int result); - bool ReadBytes(const BlobData::Item& item); - bool DispatchReadFile(const BlobData::Item& item); + bool ReadBytesItem(const BlobData::Item& item); + bool ReadFileItem(const BlobData::Item& item); - void DidOpen(base::PlatformFileError rv, - base::PassPlatformFile file, - bool created); - bool ReadFile(); - void DidRead(int result); - void CloseStream(); + void DidOpenFile(base::PlatformFileError rv, + base::PassPlatformFile file, + bool created); + bool ReadFileStream(); + void DidReadFileStream(int result); + void CloseFileStream(); int ComputeBytesToRead() const; - int ReadCompleted(); + int BytesReadCompleted(); void NotifySuccess(); void NotifyFailure(int); |