Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(380)

Side by Side Diff: chrome/browser/sync/glue/sync_backend_host.cc

Issue 11052007: Rename ModelType/ObjectIdStateMap to InvalidationMap. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: . Created 8 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "build/build_config.h" 5 #include "build/build_config.h"
6 6
7 #include "chrome/browser/sync/glue/sync_backend_host.h" 7 #include "chrome/browser/sync/glue/sync_backend_host.h"
8 8
9 #include <algorithm> 9 #include <algorithm>
10 #include <map> 10 #include <map>
(...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after
118 bool encrypt_everything) OVERRIDE; 118 bool encrypt_everything) OVERRIDE;
119 virtual void OnEncryptionComplete() OVERRIDE; 119 virtual void OnEncryptionComplete() OVERRIDE;
120 virtual void OnCryptographerStateChanged( 120 virtual void OnCryptographerStateChanged(
121 syncer::Cryptographer* cryptographer) OVERRIDE; 121 syncer::Cryptographer* cryptographer) OVERRIDE;
122 virtual void OnPassphraseTypeChanged(syncer::PassphraseType type) OVERRIDE; 122 virtual void OnPassphraseTypeChanged(syncer::PassphraseType type) OVERRIDE;
123 123
124 // syncer::InvalidationHandler implementation. 124 // syncer::InvalidationHandler implementation.
125 virtual void OnInvalidatorStateChange( 125 virtual void OnInvalidatorStateChange(
126 syncer::InvalidatorState state) OVERRIDE; 126 syncer::InvalidatorState state) OVERRIDE;
127 virtual void OnIncomingInvalidation( 127 virtual void OnIncomingInvalidation(
128 const syncer::ObjectIdStateMap& id_state_map, 128 const syncer::ObjectIdInvalidationMap& invalidation_map,
129 syncer::IncomingInvalidationSource source) OVERRIDE; 129 syncer::IncomingInvalidationSource source) OVERRIDE;
130 130
131 // Note: 131 // Note:
132 // 132 //
133 // The Do* methods are the various entry points from our 133 // The Do* methods are the various entry points from our
134 // SyncBackendHost. They are all called on the sync thread to 134 // SyncBackendHost. They are all called on the sync thread to
135 // actually perform synchronous (and potentially blocking) syncapi 135 // actually perform synchronous (and potentially blocking) syncapi
136 // operations. 136 // operations.
137 // 137 //
138 // Called to perform initialization of the syncapi on behalf of 138 // Called to perform initialization of the syncapi on behalf of
(...skipping 906 matching lines...) Expand 10 before | Expand all | Expand 10 after
1045 syncer::InvalidatorState state) { 1045 syncer::InvalidatorState state) {
1046 if (!sync_loop_) 1046 if (!sync_loop_)
1047 return; 1047 return;
1048 DCHECK_EQ(MessageLoop::current(), sync_loop_); 1048 DCHECK_EQ(MessageLoop::current(), sync_loop_);
1049 host_.Call(FROM_HERE, 1049 host_.Call(FROM_HERE,
1050 &SyncBackendHost::HandleInvalidatorStateChangeOnFrontendLoop, 1050 &SyncBackendHost::HandleInvalidatorStateChangeOnFrontendLoop,
1051 state); 1051 state);
1052 } 1052 }
1053 1053
1054 void SyncBackendHost::Core::OnIncomingInvalidation( 1054 void SyncBackendHost::Core::OnIncomingInvalidation(
1055 const syncer::ObjectIdStateMap& id_state_map, 1055 const syncer::ObjectIdInvalidationMap& invalidation_map,
1056 syncer::IncomingInvalidationSource source) { 1056 syncer::IncomingInvalidationSource source) {
1057 if (!sync_loop_) 1057 if (!sync_loop_)
1058 return; 1058 return;
1059 DCHECK_EQ(MessageLoop::current(), sync_loop_); 1059 DCHECK_EQ(MessageLoop::current(), sync_loop_);
1060 host_.Call(FROM_HERE, 1060 host_.Call(FROM_HERE,
1061 &SyncBackendHost::HandleIncomingInvalidationOnFrontendLoop, 1061 &SyncBackendHost::HandleIncomingInvalidationOnFrontendLoop,
1062 id_state_map, source); 1062 invalidation_map, source);
1063 } 1063 }
1064 1064
1065 void SyncBackendHost::Core::DoInitialize(const DoInitializeOptions& options) { 1065 void SyncBackendHost::Core::DoInitialize(const DoInitializeOptions& options) {
1066 DCHECK(!sync_loop_); 1066 DCHECK(!sync_loop_);
1067 sync_loop_ = options.sync_loop; 1067 sync_loop_ = options.sync_loop;
1068 DCHECK(sync_loop_); 1068 DCHECK(sync_loop_);
1069 1069
1070 // Blow away the partial or corrupt sync data folder before doing any more 1070 // Blow away the partial or corrupt sync data folder before doing any more
1071 // initialization, if necessary. 1071 // initialization, if necessary.
1072 if (options.delete_sync_data_folder) { 1072 if (options.delete_sync_data_folder) {
(...skipping 364 matching lines...) Expand 10 before | Expand all | Expand 10 after
1437 1437
1438 void SyncBackendHost::HandleInvalidatorStateChangeOnFrontendLoop( 1438 void SyncBackendHost::HandleInvalidatorStateChangeOnFrontendLoop(
1439 syncer::InvalidatorState state) { 1439 syncer::InvalidatorState state) {
1440 if (!frontend_) 1440 if (!frontend_)
1441 return; 1441 return;
1442 DCHECK_EQ(MessageLoop::current(), frontend_loop_); 1442 DCHECK_EQ(MessageLoop::current(), frontend_loop_);
1443 frontend_->OnInvalidatorStateChange(state); 1443 frontend_->OnInvalidatorStateChange(state);
1444 } 1444 }
1445 1445
1446 void SyncBackendHost::HandleIncomingInvalidationOnFrontendLoop( 1446 void SyncBackendHost::HandleIncomingInvalidationOnFrontendLoop(
1447 const syncer::ObjectIdStateMap& id_state_map, 1447 const syncer::ObjectIdInvalidationMap& invalidation_map,
1448 syncer::IncomingInvalidationSource source) { 1448 syncer::IncomingInvalidationSource source) {
1449 if (!frontend_) 1449 if (!frontend_)
1450 return; 1450 return;
1451 DCHECK_EQ(MessageLoop::current(), frontend_loop_); 1451 DCHECK_EQ(MessageLoop::current(), frontend_loop_);
1452 frontend_->OnIncomingInvalidation(id_state_map, source); 1452 frontend_->OnIncomingInvalidation(invalidation_map, source);
1453 } 1453 }
1454 1454
1455 bool SyncBackendHost::CheckPassphraseAgainstCachedPendingKeys( 1455 bool SyncBackendHost::CheckPassphraseAgainstCachedPendingKeys(
1456 const std::string& passphrase) const { 1456 const std::string& passphrase) const {
1457 DCHECK(cached_pending_keys_.has_blob()); 1457 DCHECK(cached_pending_keys_.has_blob());
1458 DCHECK(!passphrase.empty()); 1458 DCHECK(!passphrase.empty());
1459 syncer::Nigori nigori; 1459 syncer::Nigori nigori;
1460 nigori.InitByDerivation("localhost", "dummy", passphrase); 1460 nigori.InitByDerivation("localhost", "dummy", passphrase);
1461 std::string plaintext; 1461 std::string plaintext;
1462 bool result = nigori.Decrypt(cached_pending_keys_.blob(), &plaintext); 1462 bool result = nigori.Decrypt(cached_pending_keys_.blob(), &plaintext);
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after
1545 const syncer::ModelTypeSet failed_configuration_types) { 1545 const syncer::ModelTypeSet failed_configuration_types) {
1546 HandleInitializationCompletedOnFrontendLoop( 1546 HandleInitializationCompletedOnFrontendLoop(
1547 failed_configuration_types.Empty()); 1547 failed_configuration_types.Empty());
1548 } 1548 }
1549 1549
1550 #undef SDVLOG 1550 #undef SDVLOG
1551 1551
1552 #undef SLOG 1552 #undef SLOG
1553 1553
1554 } // namespace browser_sync 1554 } // namespace browser_sync
OLDNEW
« no previous file with comments | « chrome/browser/sync/glue/sync_backend_host.h ('k') | chrome/browser/sync/glue/sync_backend_host_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698