| Index: sync/engine/model_type_sync_proxy_impl.cc
|
| diff --git a/sync/engine/model_type_sync_proxy_impl.cc b/sync/engine/model_type_sync_proxy_impl.cc
|
| index 1d5069c586c3b59003f2c85168e927855d875217..529b5c1f35db167e2d1c2c72278002d5f327e5a9 100644
|
| --- a/sync/engine/model_type_sync_proxy_impl.cc
|
| +++ b/sync/engine/model_type_sync_proxy_impl.cc
|
| @@ -11,15 +11,14 @@
|
| #include "sync/internal_api/public/sync_context_proxy.h"
|
| #include "sync/syncable/syncable_util.h"
|
|
|
| -namespace syncer {
|
| +namespace syncer_v2 {
|
|
|
| -ModelTypeSyncProxyImpl::ModelTypeSyncProxyImpl(ModelType type)
|
| +ModelTypeSyncProxyImpl::ModelTypeSyncProxyImpl(syncer::ModelType type)
|
| : type_(type),
|
| is_preferred_(false),
|
| is_connected_(false),
|
| weak_ptr_factory_for_ui_(this),
|
| - weak_ptr_factory_for_sync_(this) {
|
| -}
|
| + weak_ptr_factory_for_sync_(this) {}
|
|
|
| ModelTypeSyncProxyImpl::~ModelTypeSyncProxyImpl() {
|
| }
|
| @@ -34,13 +33,13 @@ bool ModelTypeSyncProxyImpl::IsConnected() const {
|
| return is_connected_;
|
| }
|
|
|
| -ModelType ModelTypeSyncProxyImpl::GetModelType() const {
|
| +syncer::ModelType ModelTypeSyncProxyImpl::GetModelType() const {
|
| DCHECK(CalledOnValidThread());
|
| return type_;
|
| }
|
|
|
| void ModelTypeSyncProxyImpl::Enable(
|
| - scoped_ptr<syncer_v2::SyncContextProxy> sync_context_proxy) {
|
| + scoped_ptr<SyncContextProxy> sync_context_proxy) {
|
| DCHECK(CalledOnValidThread());
|
| DVLOG(1) << "Asked to enable " << ModelTypeToString(type_);
|
|
|
| @@ -50,7 +49,7 @@ void ModelTypeSyncProxyImpl::Enable(
|
| data_type_state_.progress_marker.set_data_type_id(
|
| GetSpecificsFieldNumberFromModelType(type_));
|
|
|
| - syncer_v2::UpdateResponseDataList saved_pending_updates = GetPendingUpdates();
|
| + UpdateResponseDataList saved_pending_updates = GetPendingUpdates();
|
| sync_context_proxy_ = sync_context_proxy.Pass();
|
| sync_context_proxy_->ConnectTypeToSync(
|
| GetModelType(),
|
| @@ -100,10 +99,10 @@ void ModelTypeSyncProxyImpl::OnConnect(scoped_ptr<ModelTypeSyncWorker> worker) {
|
|
|
| void ModelTypeSyncProxyImpl::Put(const std::string& client_tag,
|
| const sync_pb::EntitySpecifics& specifics) {
|
| - DCHECK_EQ(type_, GetModelTypeFromSpecifics(specifics));
|
| + DCHECK_EQ(type_, syncer::GetModelTypeFromSpecifics(specifics));
|
|
|
| const std::string client_tag_hash(
|
| - syncable::GenerateSyncableHash(type_, client_tag));
|
| + syncer::syncable::GenerateSyncableHash(type_, client_tag));
|
|
|
| EntityMap::const_iterator it = entities_.find(client_tag_hash);
|
| if (it == entities_.end()) {
|
| @@ -120,7 +119,7 @@ void ModelTypeSyncProxyImpl::Put(const std::string& client_tag,
|
|
|
| void ModelTypeSyncProxyImpl::Delete(const std::string& client_tag) {
|
| const std::string client_tag_hash(
|
| - syncable::GenerateSyncableHash(type_, client_tag));
|
| + syncer::syncable::GenerateSyncableHash(type_, client_tag));
|
|
|
| EntityMap::const_iterator it = entities_.find(client_tag_hash);
|
| if (it == entities_.end()) {
|
| @@ -137,7 +136,7 @@ void ModelTypeSyncProxyImpl::Delete(const std::string& client_tag) {
|
| }
|
|
|
| void ModelTypeSyncProxyImpl::FlushPendingCommitRequests() {
|
| - syncer_v2::CommitRequestDataList commit_requests;
|
| + CommitRequestDataList commit_requests;
|
|
|
| // Don't bother sending anything if there's no one to send to.
|
| if (!IsConnected())
|
| @@ -151,7 +150,7 @@ void ModelTypeSyncProxyImpl::FlushPendingCommitRequests() {
|
| for (EntityMap::const_iterator it = entities_.begin(); it != entities_.end();
|
| ++it) {
|
| if (it->second->RequiresCommitRequest()) {
|
| - syncer_v2::CommitRequestData request;
|
| + CommitRequestData request;
|
| it->second->InitializeCommitRequestData(&request);
|
| commit_requests.push_back(request);
|
| it->second->SetCommitRequestInProgress();
|
| @@ -163,14 +162,13 @@ void ModelTypeSyncProxyImpl::FlushPendingCommitRequests() {
|
| }
|
|
|
| void ModelTypeSyncProxyImpl::OnCommitCompleted(
|
| - const syncer_v2::DataTypeState& type_state,
|
| - const syncer_v2::CommitResponseDataList& response_list) {
|
| + const DataTypeState& type_state,
|
| + const CommitResponseDataList& response_list) {
|
| data_type_state_ = type_state;
|
|
|
| - for (syncer_v2::CommitResponseDataList::const_iterator list_it =
|
| - response_list.begin();
|
| + for (CommitResponseDataList::const_iterator list_it = response_list.begin();
|
| list_it != response_list.end(); ++list_it) {
|
| - const syncer_v2::CommitResponseData& response_data = *list_it;
|
| + const CommitResponseData& response_data = *list_it;
|
| const std::string& client_tag_hash = response_data.client_tag_hash;
|
|
|
| EntityMap::const_iterator it = entities_.find(client_tag_hash);
|
| @@ -188,18 +186,17 @@ void ModelTypeSyncProxyImpl::OnCommitCompleted(
|
| }
|
|
|
| void ModelTypeSyncProxyImpl::OnUpdateReceived(
|
| - const syncer_v2::DataTypeState& data_type_state,
|
| - const syncer_v2::UpdateResponseDataList& response_list,
|
| - const syncer_v2::UpdateResponseDataList& pending_updates) {
|
| + const DataTypeState& data_type_state,
|
| + const UpdateResponseDataList& response_list,
|
| + const UpdateResponseDataList& pending_updates) {
|
| bool got_new_encryption_requirements = data_type_state_.encryption_key_name !=
|
| data_type_state.encryption_key_name;
|
|
|
| data_type_state_ = data_type_state;
|
|
|
| - for (syncer_v2::UpdateResponseDataList::const_iterator list_it =
|
| - response_list.begin();
|
| + for (UpdateResponseDataList::const_iterator list_it = response_list.begin();
|
| list_it != response_list.end(); ++list_it) {
|
| - const syncer_v2::UpdateResponseData& response_data = *list_it;
|
| + const UpdateResponseData& response_data = *list_it;
|
| const std::string& client_tag_hash = response_data.client_tag_hash;
|
|
|
| // If we're being asked to apply an update to this entity, this overrides
|
| @@ -244,23 +241,20 @@ void ModelTypeSyncProxyImpl::OnUpdateReceived(
|
| }
|
|
|
| // Save pending updates in the appropriate data structure.
|
| - for (syncer_v2::UpdateResponseDataList::const_iterator list_it =
|
| - pending_updates.begin();
|
| + for (UpdateResponseDataList::const_iterator list_it = pending_updates.begin();
|
| list_it != pending_updates.end(); ++list_it) {
|
| - const syncer_v2::UpdateResponseData& update = *list_it;
|
| + const UpdateResponseData& update = *list_it;
|
| const std::string& client_tag_hash = update.client_tag_hash;
|
|
|
| UpdateMap::const_iterator lookup_it =
|
| pending_updates_map_.find(client_tag_hash);
|
| if (lookup_it == pending_updates_map_.end()) {
|
| pending_updates_map_.insert(
|
| - client_tag_hash,
|
| - make_scoped_ptr(new syncer_v2::UpdateResponseData(update)));
|
| + client_tag_hash, make_scoped_ptr(new UpdateResponseData(update)));
|
| } else if (lookup_it->second->response_version <= update.response_version) {
|
| pending_updates_map_.erase(lookup_it);
|
| pending_updates_map_.insert(
|
| - client_tag_hash,
|
| - make_scoped_ptr(new syncer_v2::UpdateResponseData(update)));
|
| + client_tag_hash, make_scoped_ptr(new UpdateResponseData(update)));
|
| } else {
|
| // Received update is stale, do not overwrite existing.
|
| }
|
| @@ -281,8 +275,8 @@ void ModelTypeSyncProxyImpl::OnUpdateReceived(
|
| // TODO: Persist the new data on disk.
|
| }
|
|
|
| -syncer_v2::UpdateResponseDataList ModelTypeSyncProxyImpl::GetPendingUpdates() {
|
| - syncer_v2::UpdateResponseDataList pending_updates_list;
|
| +UpdateResponseDataList ModelTypeSyncProxyImpl::GetPendingUpdates() {
|
| + UpdateResponseDataList pending_updates_list;
|
| for (UpdateMap::const_iterator it = pending_updates_map_.begin();
|
| it != pending_updates_map_.end();
|
| ++it) {
|
| @@ -304,7 +298,7 @@ void ModelTypeSyncProxyImpl::ClearSyncState() {
|
| it->second->ClearSyncState();
|
| }
|
| pending_updates_map_.clear();
|
| - data_type_state_ = syncer_v2::DataTypeState();
|
| + data_type_state_ = DataTypeState();
|
| }
|
|
|
| } // namespace syncer
|
|
|