Index: chrome/browser/chromeos/gdata/operation_registry.cc |
diff --git a/chrome/browser/chromeos/gdata/gdata_operation_registry.cc b/chrome/browser/chromeos/gdata/operation_registry.cc |
similarity index 80% |
rename from chrome/browser/chromeos/gdata/gdata_operation_registry.cc |
rename to chrome/browser/chromeos/gdata/operation_registry.cc |
index 287691fba62f01337b9115133f6ef50d50ead0e9..5d4a0766a2bedc7bc125564aebc3508c143d658f 100644 |
--- a/chrome/browser/chromeos/gdata/gdata_operation_registry.cc |
+++ b/chrome/browser/chromeos/gdata/operation_registry.cc |
@@ -2,7 +2,7 @@ |
// 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_operation_registry.h" |
+#include "chrome/browser/chromeos/gdata/operation_registry.h" |
#include "base/string_number_conversions.h" |
#include "content/public/browser/browser_thread.h" |
@@ -18,7 +18,7 @@ const int64 kNotificationFrequencyInMilliseconds = 1000; |
namespace gdata { |
// static |
-std::string GDataOperationRegistry::OperationTypeToString(OperationType type) { |
+std::string OperationRegistry::OperationTypeToString(OperationType type) { |
switch (type) { |
case OPERATION_UPLOAD: return "upload"; |
case OPERATION_DOWNLOAD: return "download"; |
@@ -29,7 +29,7 @@ std::string GDataOperationRegistry::OperationTypeToString(OperationType type) { |
} |
// static |
-std::string GDataOperationRegistry::OperationTransferStateToString( |
+std::string OperationRegistry::OperationTransferStateToString( |
OperationTransferState state) { |
switch (state) { |
case OPERATION_NOT_STARTED: return "not_started"; |
@@ -44,7 +44,7 @@ std::string GDataOperationRegistry::OperationTransferStateToString( |
return "unknown_transfer_state"; |
} |
-GDataOperationRegistry::ProgressStatus::ProgressStatus(OperationType type, |
+OperationRegistry::ProgressStatus::ProgressStatus(OperationType type, |
const FilePath& path) |
: operation_id(-1), |
operation_type(type), |
@@ -54,7 +54,7 @@ GDataOperationRegistry::ProgressStatus::ProgressStatus(OperationType type, |
progress_total(-1) { |
} |
-std::string GDataOperationRegistry::ProgressStatus::DebugString() const { |
+std::string OperationRegistry::ProgressStatus::DebugString() const { |
std::string str; |
str += "id="; |
str += base::IntToString(operation_id); |
@@ -71,30 +71,30 @@ std::string GDataOperationRegistry::ProgressStatus::DebugString() const { |
return str; |
} |
-GDataOperationRegistry::Operation::Operation(GDataOperationRegistry* registry) |
+OperationRegistry::Operation::Operation(OperationRegistry* registry) |
: registry_(registry), |
- progress_status_(GDataOperationRegistry::OPERATION_OTHER, FilePath()) { |
+ progress_status_(OperationRegistry::OPERATION_OTHER, FilePath()) { |
} |
-GDataOperationRegistry::Operation::Operation(GDataOperationRegistry* registry, |
+OperationRegistry::Operation::Operation(OperationRegistry* registry, |
OperationType type, |
const FilePath& path) |
: registry_(registry), |
progress_status_(type, path) { |
} |
-GDataOperationRegistry::Operation::~Operation() { |
+OperationRegistry::Operation::~Operation() { |
DCHECK(progress_status_.transfer_state == OPERATION_COMPLETED || |
progress_status_.transfer_state == OPERATION_SUSPENDED || |
progress_status_.transfer_state == OPERATION_FAILED); |
} |
-void GDataOperationRegistry::Operation::Cancel() { |
+void OperationRegistry::Operation::Cancel() { |
DoCancel(); |
NotifyFinish(OPERATION_FAILED); |
} |
-void GDataOperationRegistry::Operation::NotifyStart() { |
+void OperationRegistry::Operation::NotifyStart() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
// Some operations may be restarted. Report only the first "start". |
if (progress_status_.transfer_state == OPERATION_NOT_STARTED) { |
@@ -104,7 +104,7 @@ void GDataOperationRegistry::Operation::NotifyStart() { |
} |
} |
-void GDataOperationRegistry::Operation::NotifyProgress( |
+void OperationRegistry::Operation::NotifyProgress( |
int64 current, int64 total) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(progress_status_.transfer_state >= OPERATION_STARTED); |
@@ -114,7 +114,7 @@ void GDataOperationRegistry::Operation::NotifyProgress( |
registry_->OnOperationProgress(progress_status().operation_id); |
} |
-void GDataOperationRegistry::Operation::NotifyFinish( |
+void OperationRegistry::Operation::NotifyFinish( |
OperationTransferState status) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(progress_status_.transfer_state >= OPERATION_STARTED); |
@@ -123,14 +123,14 @@ void GDataOperationRegistry::Operation::NotifyFinish( |
registry_->OnOperationFinish(progress_status().operation_id); |
} |
-void GDataOperationRegistry::Operation::NotifySuspend() { |
+void OperationRegistry::Operation::NotifySuspend() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DCHECK(progress_status_.transfer_state >= OPERATION_STARTED); |
progress_status_.transfer_state = OPERATION_SUSPENDED; |
registry_->OnOperationSuspend(progress_status().operation_id); |
} |
-void GDataOperationRegistry::Operation::NotifyResume() { |
+void OperationRegistry::Operation::NotifyResume() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
if (progress_status_.transfer_state == OPERATION_NOT_STARTED) { |
progress_status_.transfer_state = OPERATION_IN_PROGRESS; |
@@ -138,33 +138,33 @@ void GDataOperationRegistry::Operation::NotifyResume() { |
} |
} |
-void GDataOperationRegistry::Operation::NotifyAuthFailed() { |
+void OperationRegistry::Operation::NotifyAuthFailed() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
registry_->OnOperationAuthFailed(); |
} |
-GDataOperationRegistry::GDataOperationRegistry() |
+OperationRegistry::OperationRegistry() |
: do_notification_frequency_control_(true) { |
in_flight_operations_.set_check_on_null_data(true); |
} |
-GDataOperationRegistry::~GDataOperationRegistry() { |
+OperationRegistry::~OperationRegistry() { |
DCHECK(in_flight_operations_.IsEmpty()); |
} |
-void GDataOperationRegistry::AddObserver(Observer* observer) { |
+void OperationRegistry::AddObserver(Observer* observer) { |
observer_list_.AddObserver(observer); |
} |
-void GDataOperationRegistry::RemoveObserver(Observer* observer) { |
+void OperationRegistry::RemoveObserver(Observer* observer) { |
observer_list_.RemoveObserver(observer); |
} |
-void GDataOperationRegistry::DisableNotificationFrequencyControlForTest() { |
+void OperationRegistry::DisableNotificationFrequencyControlForTest() { |
do_notification_frequency_control_ = false; |
} |
-void GDataOperationRegistry::CancelAll() { |
+void OperationRegistry::CancelAll() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
for (OperationIDMap::iterator iter(&in_flight_operations_); |
@@ -178,7 +178,7 @@ void GDataOperationRegistry::CancelAll() { |
} |
} |
-bool GDataOperationRegistry::CancelForFilePath(const FilePath& file_path) { |
+bool OperationRegistry::CancelForFilePath(const FilePath& file_path) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
for (OperationIDMap::iterator iter(&in_flight_operations_); |
@@ -193,8 +193,8 @@ bool GDataOperationRegistry::CancelForFilePath(const FilePath& file_path) { |
return false; |
} |
-void GDataOperationRegistry::OnOperationStart( |
- GDataOperationRegistry::Operation* operation, |
+void OperationRegistry::OnOperationStart( |
+ OperationRegistry::Operation* operation, |
OperationID* id) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
@@ -204,7 +204,7 @@ void GDataOperationRegistry::OnOperationStart( |
NotifyStatusToObservers(); |
} |
-void GDataOperationRegistry::OnOperationProgress(OperationID id) { |
+void OperationRegistry::OnOperationProgress(OperationID id) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
Operation* operation = in_flight_operations_.Lookup(id); |
@@ -216,7 +216,7 @@ void GDataOperationRegistry::OnOperationProgress(OperationID id) { |
NotifyStatusToObservers(); |
} |
-void GDataOperationRegistry::OnOperationFinish(OperationID id) { |
+void OperationRegistry::OnOperationFinish(OperationID id) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
Operation* operation = in_flight_operations_.Lookup(id); |
@@ -228,9 +228,9 @@ void GDataOperationRegistry::OnOperationFinish(OperationID id) { |
in_flight_operations_.Remove(id); |
} |
-void GDataOperationRegistry::OnOperationResume( |
- GDataOperationRegistry::Operation* operation, |
- GDataOperationRegistry::ProgressStatus* new_status) { |
+void OperationRegistry::OnOperationResume( |
+ OperationRegistry::Operation* operation, |
+ OperationRegistry::ProgressStatus* new_status) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
// Find the corresponding suspended task. |
@@ -265,7 +265,7 @@ void GDataOperationRegistry::OnOperationResume( |
NotifyStatusToObservers(); |
} |
-void GDataOperationRegistry::OnOperationSuspend(OperationID id) { |
+void OperationRegistry::OnOperationSuspend(OperationID id) { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
Operation* operation = in_flight_operations_.Lookup(id); |
@@ -276,21 +276,21 @@ void GDataOperationRegistry::OnOperationSuspend(OperationID id) { |
NotifyStatusToObservers(); |
} |
-void GDataOperationRegistry::OnOperationAuthFailed() { |
+void OperationRegistry::OnOperationAuthFailed() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
DVLOG(1) << "GDataOperation authentication failed."; |
FOR_EACH_OBSERVER(Observer, observer_list_, OnAuthenticationFailed()); |
} |
-bool GDataOperationRegistry::IsFileTransferOperation( |
+bool OperationRegistry::IsFileTransferOperation( |
const Operation* operation) const { |
OperationType type = operation->progress_status().operation_type; |
return type == OPERATION_UPLOAD || type == OPERATION_DOWNLOAD; |
} |
-GDataOperationRegistry::ProgressStatusList |
-GDataOperationRegistry::GetProgressStatusList() { |
+OperationRegistry::ProgressStatusList |
+OperationRegistry::GetProgressStatusList() { |
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
ProgressStatusList status_list; |
@@ -304,7 +304,7 @@ GDataOperationRegistry::GetProgressStatusList() { |
return status_list; |
} |
-bool GDataOperationRegistry::ShouldNotifyStatusNow( |
+bool OperationRegistry::ShouldNotifyStatusNow( |
const ProgressStatusList& list) { |
if (!do_notification_frequency_control_) |
return true; |
@@ -339,7 +339,7 @@ bool GDataOperationRegistry::ShouldNotifyStatusNow( |
return false; |
} |
-void GDataOperationRegistry::NotifyStatusToObservers() { |
+void OperationRegistry::NotifyStatusToObservers() { |
ProgressStatusList list(GetProgressStatusList()); |
if (ShouldNotifyStatusNow(list)) |
FOR_EACH_OBSERVER(Observer, observer_list_, OnProgressUpdate(list)); |