summaryrefslogtreecommitdiffstats
path: root/components/sync_driver/non_blocking_data_type_controller.cc
diff options
context:
space:
mode:
authorrlarocque@chromium.org <rlarocque@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-06-25 05:52:32 +0000
committerrlarocque@chromium.org <rlarocque@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-06-25 05:52:32 +0000
commit973a446349b8b98f8ebb35da2ae204ee71047d0c (patch)
tree1893a2d9fef2d0023ec9a561d77911e7634f3cdb /components/sync_driver/non_blocking_data_type_controller.cc
parent633a10a8162d96014ecb1ddcd01e1bb1e584d6c1 (diff)
downloadchromium_src-973a446349b8b98f8ebb35da2ae204ee71047d0c.zip
chromium_src-973a446349b8b98f8ebb35da2ae204ee71047d0c.tar.gz
chromium_src-973a446349b8b98f8ebb35da2ae204ee71047d0c.tar.bz2
sync: Mass rename of non-blocking sync classes
Renames many of the classes involved in non-blocking sync: - Renames SyncCore, SyncCoreProxy to SyncContext and SyncContextProxy. - Renames NonBlockingTypeProcessor and NonBlockingTypeProcessorInterface to ModelTypeSyncProxyImpl and ModelTypeSyncProxy, respectively. - Renames NonBlockingTypeProcessorCore and NonBlockingTypeProcessorCoreInterface to ModelTypeSyncWorkerImpl and ModelTypeSyncWorker, respectively. - Renames ModelThreadSyncEntity to ModelTypeEntity. - Renames SyncThreadSyncEntity to EntityTracker. Renames any Mock, Test, Wrapper, or Impl classes associated with the above, too. This is only the first part of the planned refactoring. The second part, which involves some changes to the inheritance hierarchy, will be implemented in a future CL. BUG=351005 Review URL: https://codereview.chromium.org/351523003 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@279618 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'components/sync_driver/non_blocking_data_type_controller.cc')
-rw-r--r--components/sync_driver/non_blocking_data_type_controller.cc59
1 files changed, 30 insertions, 29 deletions
diff --git a/components/sync_driver/non_blocking_data_type_controller.cc b/components/sync_driver/non_blocking_data_type_controller.cc
index 55af708..21b1dab 100644
--- a/components/sync_driver/non_blocking_data_type_controller.cc
+++ b/components/sync_driver/non_blocking_data_type_controller.cc
@@ -7,7 +7,7 @@
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/location.h"
-#include "sync/engine/non_blocking_type_processor.h"
+#include "sync/engine/model_type_sync_proxy_impl.h"
namespace browser_sync {
@@ -19,30 +19,30 @@ NonBlockingDataTypeController::NonBlockingDataTypeController(
NonBlockingDataTypeController::~NonBlockingDataTypeController() {}
-void NonBlockingDataTypeController::InitializeProcessor(
- scoped_refptr<base::SequencedTaskRunner> task_runner,
- base::WeakPtr<syncer::NonBlockingTypeProcessor> processor) {
- DCHECK(!IsTypeProcessorConnected());
+void NonBlockingDataTypeController::InitializeType(
+ const scoped_refptr<base::SequencedTaskRunner>& task_runner,
+ const base::WeakPtr<syncer::ModelTypeSyncProxyImpl>& type_sync_proxy) {
+ DCHECK(!IsSyncProxyConnected());
task_runner_ = task_runner;
- processor_ = processor;
- DCHECK(IsTypeProcessorConnected());
+ type_sync_proxy_ = type_sync_proxy;
+ DCHECK(IsSyncProxyConnected());
UpdateState();
}
-void NonBlockingDataTypeController::InitializeSyncCoreProxy(
- scoped_ptr<syncer::SyncCoreProxy> proxy) {
+void NonBlockingDataTypeController::InitializeSyncContext(
+ scoped_ptr<syncer::SyncContextProxy> sync_context_proxy) {
DCHECK(!IsSyncBackendConnected());
- proxy_ = proxy.Pass();
+ sync_context_proxy_ = sync_context_proxy.Pass();
UpdateState();
}
-void NonBlockingDataTypeController::ClearSyncCoreProxy() {
- // Never had a sync core proxy to begin with. No change.
- if (!proxy_)
+void NonBlockingDataTypeController::ClearSyncContext() {
+ // Never had a sync context proxy to begin with. No change.
+ if (!sync_context_proxy_)
return;
- proxy_.reset();
+ sync_context_proxy_.reset();
UpdateState();
}
@@ -59,12 +59,12 @@ void NonBlockingDataTypeController::UpdateState() {
return;
}
- // Return immediately if the processor is not ready yet.
- if (!IsTypeProcessorConnected()) {
+ // Return immediately if the sync context proxy is not ready yet.
+ if (!IsSyncProxyConnected()) {
return;
}
- // Send the appropriate state transition request to the processor.
+ // Send the appropriate state transition request to the type sync proxy.
switch (GetDesiredState()) {
case ENABLED:
SendEnableSignal();
@@ -84,10 +84,11 @@ void NonBlockingDataTypeController::SendEnableSignal() {
DCHECK_EQ(ENABLED, GetDesiredState());
DVLOG(1) << "Enabling non-blocking sync type " << ModelTypeToString(type_);
- task_runner_->PostTask(FROM_HERE,
- base::Bind(&syncer::NonBlockingTypeProcessor::Enable,
- processor_,
- base::Passed(proxy_->Clone())));
+ task_runner_->PostTask(
+ FROM_HERE,
+ base::Bind(&syncer::ModelTypeSyncProxyImpl::Enable,
+ type_sync_proxy_,
+ base::Passed(sync_context_proxy_->Clone())));
current_state_ = ENABLED;
}
@@ -96,7 +97,7 @@ void NonBlockingDataTypeController::SendDisableSignal() {
DVLOG(1) << "Disabling non-blocking sync type " << ModelTypeToString(type_);
task_runner_->PostTask(
FROM_HERE,
- base::Bind(&syncer::NonBlockingTypeProcessor::Disable, processor_));
+ base::Bind(&syncer::ModelTypeSyncProxyImpl::Disable, type_sync_proxy_));
current_state_ = DISABLED;
}
@@ -104,9 +105,9 @@ void NonBlockingDataTypeController::SendDisconnectSignal() {
DCHECK_EQ(DISCONNECTED, GetDesiredState());
DVLOG(1) << "Disconnecting non-blocking sync type "
<< ModelTypeToString(type_);
- task_runner_->PostTask(
- FROM_HERE,
- base::Bind(&syncer::NonBlockingTypeProcessor::Disconnect, processor_));
+ task_runner_->PostTask(FROM_HERE,
+ base::Bind(&syncer::ModelTypeSyncProxyImpl::Disconnect,
+ type_sync_proxy_));
current_state_ = DISCONNECTED;
}
@@ -114,19 +115,19 @@ bool NonBlockingDataTypeController::IsPreferred() const {
return is_preferred_;
}
-bool NonBlockingDataTypeController::IsTypeProcessorConnected() const {
+bool NonBlockingDataTypeController::IsSyncProxyConnected() const {
return task_runner_ != NULL;
}
bool NonBlockingDataTypeController::IsSyncBackendConnected() const {
- return proxy_;
+ return sync_context_proxy_;
}
-NonBlockingDataTypeController::TypeProcessorState
+NonBlockingDataTypeController::TypeState
NonBlockingDataTypeController::GetDesiredState() const {
if (!IsPreferred()) {
return DISABLED;
- } else if (!IsSyncBackendConnected() || !IsTypeProcessorConnected()) {
+ } else if (!IsSyncBackendConnected() || !IsSyncProxyConnected()) {
return DISCONNECTED;
} else {
return ENABLED;