Index: chrome/browser/chromeos/gdata/drive_uploader.cc |
diff --git a/chrome/browser/chromeos/gdata/gdata_uploader.cc b/chrome/browser/chromeos/gdata/drive_uploader.cc |
similarity index 91% |
rename from chrome/browser/chromeos/gdata/gdata_uploader.cc |
rename to chrome/browser/chromeos/gdata/drive_uploader.cc |
index 32212d089d02902480c48c8b26e2c38794ed9cb0..1b5819294d2996603bfadbeea673f6c5b60a9a03 100644 |
--- a/chrome/browser/chromeos/gdata/gdata_uploader.cc |
+++ b/chrome/browser/chromeos/gdata/drive_uploader.cc |
@@ -2,14 +2,14 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "chrome/browser/chromeos/gdata/gdata_uploader.h" |
+#include "chrome/browser/chromeos/gdata/drive_uploader.h" |
#include <algorithm> |
#include "base/bind.h" |
#include "base/callback.h" |
#include "chrome/browser/chromeos/gdata/drive_service_interface.h" |
-#include "chrome/browser/chromeos/gdata/gdata_upload_file_info.h" |
+#include "chrome/browser/chromeos/gdata/drive_upload_file_info.h" |
#include "chrome/browser/chromeos/gdata/gdata_wapi_parser.h" |
#include "content/public/browser/browser_thread.h" |
#include "content/public/browser/download_item.h" |
@@ -30,21 +30,21 @@ const int kMaxFileOpenTries = 5; |
namespace gdata { |
-GDataUploader::GDataUploader(DriveServiceInterface* drive_service) |
+DriveUploader::DriveUploader(DriveServiceInterface* drive_service) |
: drive_service_(drive_service), |
next_upload_id_(0), |
ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { |
} |
-GDataUploader::~GDataUploader() { |
+DriveUploader::~DriveUploader() { |
} |
-int GDataUploader::UploadNewFile(scoped_ptr<UploadFileInfo> upload_file_info) { |
+int DriveUploader::UploadNewFile(scoped_ptr<UploadFileInfo> upload_file_info) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(upload_file_info.get()); |
DCHECK_EQ(upload_file_info->upload_id, -1); |
DCHECK(!upload_file_info->file_path.empty()); |
- DCHECK(!upload_file_info->gdata_path.empty()); |
+ DCHECK(!upload_file_info->drive_path.empty()); |
DCHECK(!upload_file_info->title.empty()); |
DCHECK(!upload_file_info->content_type.empty()); |
DCHECK(!upload_file_info->initial_upload_location.is_empty()); |
@@ -60,13 +60,13 @@ int GDataUploader::UploadNewFile(scoped_ptr<UploadFileInfo> upload_file_info) { |
return StartUploadFile(upload_file_info.Pass()); |
} |
-int GDataUploader::StreamExistingFile( |
+int DriveUploader::StreamExistingFile( |
scoped_ptr<UploadFileInfo> upload_file_info) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(upload_file_info.get()); |
DCHECK_EQ(upload_file_info->upload_id, -1); |
DCHECK(!upload_file_info->file_path.empty()); |
- DCHECK(!upload_file_info->gdata_path.empty()); |
+ DCHECK(!upload_file_info->drive_path.empty()); |
DCHECK(upload_file_info->title.empty()); |
DCHECK(!upload_file_info->content_type.empty()); |
DCHECK(!upload_file_info->initial_upload_location.is_empty()); |
@@ -82,7 +82,7 @@ int GDataUploader::StreamExistingFile( |
return StartUploadFile(upload_file_info.Pass()); |
} |
-int GDataUploader::StartUploadFile( |
+int DriveUploader::StartUploadFile( |
scoped_ptr<UploadFileInfo> upload_file_info) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(upload_file_info.get()); |
@@ -110,9 +110,9 @@ int GDataUploader::StartUploadFile( |
return upload_id; |
} |
-int GDataUploader::UploadExistingFile( |
+int DriveUploader::UploadExistingFile( |
const GURL& upload_location, |
- const FilePath& gdata_file_path, |
+ const FilePath& drive_file_path, |
const FilePath& local_file_path, |
int64 file_size, |
const std::string& content_type, |
@@ -129,7 +129,7 @@ int GDataUploader::UploadExistingFile( |
upload_file_info->file_size = file_size; |
upload_file_info->content_type = content_type; |
upload_file_info->completion_callback = callback; |
- upload_file_info->gdata_path = gdata_file_path, |
+ upload_file_info->drive_path = drive_file_path, |
upload_file_info->content_length = file_size; |
upload_file_info->all_bytes_present = true; |
@@ -139,7 +139,7 @@ int GDataUploader::UploadExistingFile( |
return StartUploadFile(upload_file_info.Pass()); |
} |
-void GDataUploader::UpdateUpload(int upload_id, |
+void DriveUploader::UpdateUpload(int upload_id, |
content::DownloadItem* download) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
@@ -189,7 +189,7 @@ void GDataUploader::UpdateUpload(int upload_id, |
} |
} |
-int64 GDataUploader::GetUploadedBytes(int upload_id) const { |
+int64 DriveUploader::GetUploadedBytes(int upload_id) const { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
UploadFileInfo* upload_info = GetUploadFileInfo(upload_id); |
// We return the start_range as the count of uploaded bytes since that is the |
@@ -199,7 +199,7 @@ int64 GDataUploader::GetUploadedBytes(int upload_id) const { |
return upload_info ? upload_info->start_range : 0; |
} |
-UploadFileInfo* GDataUploader::GetUploadFileInfo(int upload_id) const { |
+UploadFileInfo* DriveUploader::GetUploadFileInfo(int upload_id) const { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
UploadFileInfoMap::const_iterator it = pending_uploads_.find(upload_id); |
@@ -208,20 +208,20 @@ UploadFileInfo* GDataUploader::GetUploadFileInfo(int upload_id) const { |
return it != pending_uploads_.end() ? it->second : NULL; |
} |
-void GDataUploader::OpenFile(UploadFileInfo* upload_file_info) { |
+void DriveUploader::OpenFile(UploadFileInfo* upload_file_info) { |
// Open the file asynchronously. |
const int rv = upload_file_info->file_stream->Open( |
upload_file_info->file_path, |
base::PLATFORM_FILE_OPEN | |
base::PLATFORM_FILE_READ | |
base::PLATFORM_FILE_ASYNC, |
- base::Bind(&GDataUploader::OpenCompletionCallback, |
+ base::Bind(&DriveUploader::OpenCompletionCallback, |
weak_ptr_factory_.GetWeakPtr(), |
upload_file_info->upload_id)); |
DCHECK_EQ(net::ERR_IO_PENDING, rv); |
} |
-void GDataUploader::OpenCompletionCallback(int upload_id, int result) { |
+void DriveUploader::OpenCompletionCallback(int upload_id, int result) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
UploadFileInfo* upload_file_info = GetUploadFileInfo(upload_id); |
@@ -267,13 +267,13 @@ void GDataUploader::OpenCompletionCallback(int upload_id, int result) { |
upload_file_info->content_type, |
upload_file_info->content_length, |
upload_file_info->initial_upload_location, |
- upload_file_info->gdata_path), |
- base::Bind(&GDataUploader::OnUploadLocationReceived, |
+ upload_file_info->drive_path), |
+ base::Bind(&DriveUploader::OnUploadLocationReceived, |
weak_ptr_factory_.GetWeakPtr(), |
upload_file_info->upload_id)); |
} |
-void GDataUploader::OnUploadLocationReceived( |
+void DriveUploader::OnUploadLocationReceived( |
int upload_id, |
GDataErrorCode code, |
const GURL& upload_location) { |
@@ -299,7 +299,7 @@ void GDataUploader::OnUploadLocationReceived( |
UploadNextChunk(upload_file_info); |
} |
-void GDataUploader::UploadNextChunk(UploadFileInfo* upload_file_info) { |
+void DriveUploader::UploadNextChunk(UploadFileInfo* upload_file_info) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
// Check that |upload_file_info| is in pending_uploads_. |
DCHECK(upload_file_info == GetUploadFileInfo(upload_file_info->upload_id)); |
@@ -342,7 +342,7 @@ void GDataUploader::UploadNextChunk(UploadFileInfo* upload_file_info) { |
// finished yet. |
base::MessageLoopProxy::current()->PostTask( |
FROM_HERE, |
- base::Bind(&GDataUploader::ResumeUpload, |
+ base::Bind(&DriveUploader::ResumeUpload, |
weak_ptr_factory_.GetWeakPtr(), |
upload_file_info->upload_id)); |
return; |
@@ -351,13 +351,13 @@ void GDataUploader::UploadNextChunk(UploadFileInfo* upload_file_info) { |
upload_file_info->file_stream->Read( |
upload_file_info->buf, |
bytes_to_read, |
- base::Bind(&GDataUploader::ReadCompletionCallback, |
+ base::Bind(&DriveUploader::ReadCompletionCallback, |
weak_ptr_factory_.GetWeakPtr(), |
upload_file_info->upload_id, |
bytes_to_read)); |
} |
-void GDataUploader::ReadCompletionCallback( |
+void DriveUploader::ReadCompletionCallback( |
int upload_id, |
int bytes_to_read, |
int bytes_read) { |
@@ -382,7 +382,7 @@ void GDataUploader::ReadCompletionCallback( |
ResumeUpload(upload_id); |
} |
-void GDataUploader::ResumeUpload(int upload_id) { |
+void DriveUploader::ResumeUpload(int upload_id) { |
UploadFileInfo* upload_file_info = GetUploadFileInfo(upload_id); |
if (!upload_file_info) |
return; |
@@ -395,13 +395,13 @@ void GDataUploader::ResumeUpload(int upload_id) { |
upload_file_info->content_type, |
upload_file_info->buf, |
upload_file_info->upload_location, |
- upload_file_info->gdata_path), |
- base::Bind(&GDataUploader::OnResumeUploadResponseReceived, |
+ upload_file_info->drive_path), |
+ base::Bind(&DriveUploader::OnResumeUploadResponseReceived, |
weak_ptr_factory_.GetWeakPtr(), |
upload_file_info->upload_id)); |
} |
-void GDataUploader::OnResumeUploadResponseReceived( |
+void DriveUploader::OnResumeUploadResponseReceived( |
int upload_id, |
const ResumeUploadResponse& response, |
scoped_ptr<DocumentEntry> entry) { |
@@ -460,7 +460,7 @@ void GDataUploader::OnResumeUploadResponseReceived( |
UploadNextChunk(upload_file_info); |
} |
-void GDataUploader::UploadFailed(scoped_ptr<UploadFileInfo> upload_file_info, |
+void DriveUploader::UploadFailed(scoped_ptr<UploadFileInfo> upload_file_info, |
DriveFileError error) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
@@ -475,7 +475,7 @@ void GDataUploader::UploadFailed(scoped_ptr<UploadFileInfo> upload_file_info, |
callback.Run(error, upload_file_info.Pass()); |
} |
-void GDataUploader::RemoveUpload(int upload_id) { |
+void DriveUploader::RemoveUpload(int upload_id) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
pending_uploads_.erase(upload_id); |
} |