OLD | NEW |
---|---|
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 "chrome/browser/sync/syncable/syncable.h" | 5 #include "chrome/browser/sync/syncable/syncable.h" |
6 | 6 |
7 #include "build/build_config.h" | 7 #include "build/build_config.h" |
8 | 8 |
9 #include <sys/stat.h> | 9 #include <sys/stat.h> |
10 #if defined(OS_POSIX) | 10 #if defined(OS_POSIX) |
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
172 void Directory::init_kernel(const std::string& name) { | 172 void Directory::init_kernel(const std::string& name) { |
173 DCHECK(kernel_ == NULL); | 173 DCHECK(kernel_ == NULL); |
174 kernel_ = new Kernel(FilePath(), name, KernelLoadInfo()); | 174 kernel_ = new Kernel(FilePath(), name, KernelLoadInfo()); |
175 } | 175 } |
176 | 176 |
177 Directory::PersistedKernelInfo::PersistedKernelInfo() | 177 Directory::PersistedKernelInfo::PersistedKernelInfo() |
178 : next_id(0) { | 178 : next_id(0) { |
179 for (int i = 0; i < MODEL_TYPE_COUNT; ++i) { | 179 for (int i = 0; i < MODEL_TYPE_COUNT; ++i) { |
180 last_download_timestamp[i] = 0; | 180 last_download_timestamp[i] = 0; |
181 } | 181 } |
182 autofill_migration_state = NOT_DETERMINED; | |
182 } | 183 } |
183 | 184 |
184 Directory::PersistedKernelInfo::~PersistedKernelInfo() {} | 185 Directory::PersistedKernelInfo::~PersistedKernelInfo() {} |
185 | 186 |
186 Directory::SaveChangesSnapshot::SaveChangesSnapshot() | 187 Directory::SaveChangesSnapshot::SaveChangesSnapshot() |
187 : kernel_info_status(KERNEL_SHARE_INFO_INVALID) { | 188 : kernel_info_status(KERNEL_SHARE_INFO_INVALID) { |
188 } | 189 } |
189 | 190 |
190 Directory::SaveChangesSnapshot::~SaveChangesSnapshot() {} | 191 Directory::SaveChangesSnapshot::~SaveChangesSnapshot() {} |
191 | 192 |
(...skipping 521 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
713 int64 timestamp) { | 714 int64 timestamp) { |
714 ScopedKernelLock lock(this); | 715 ScopedKernelLock lock(this); |
715 set_last_download_timestamp_unsafe(model_type, timestamp); | 716 set_last_download_timestamp_unsafe(model_type, timestamp); |
716 } | 717 } |
717 | 718 |
718 bool Directory::initial_sync_ended_for_type(ModelType type) const { | 719 bool Directory::initial_sync_ended_for_type(ModelType type) const { |
719 ScopedKernelLock lock(this); | 720 ScopedKernelLock lock(this); |
720 return kernel_->persisted_info.initial_sync_ended[type]; | 721 return kernel_->persisted_info.initial_sync_ended[type]; |
721 } | 722 } |
722 | 723 |
724 AutofillMigrationState Directory::get_autofill_migration_state() const { | |
725 ScopedKernelLock lock(this); | |
726 return kernel_->persisted_info.autofill_migration_state; | |
727 } | |
728 | |
729 AutofillMigrationDebugInfo | |
730 Directory::get_autofill_migration_debug_info() const { | |
731 ScopedKernelLock lock(this); | |
732 return kernel_->persisted_info.autofill_migration_debug_info; | |
733 } | |
734 | |
735 template <class T> void Directory::TestAndSet( | |
736 T* kernel_data, const T* data_to_set) { | |
737 if (*kernel_data != *data_to_set) { | |
738 *kernel_data = *data_to_set; | |
739 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY; | |
740 } | |
741 } | |
742 | |
743 void Directory::set_autofill_migration_state_debug_info( | |
744 AutofillMigrationDebugInfo::PropertyToSet property_to_set, | |
745 const AutofillMigrationDebugInfo& info) { | |
746 | |
747 ScopedKernelLock lock(this); | |
748 switch (property_to_set) { | |
749 case AutofillMigrationDebugInfo::MIGRATION_TIME: { | |
750 syncable::AutofillMigrationDebugInfo& | |
751 debug_info = kernel_->persisted_info.autofill_migration_debug_info; | |
752 TestAndSet<int64>( | |
753 &debug_info.autofill_migration_time, | |
754 &info.autofill_migration_time); | |
755 break; | |
756 } | |
757 case AutofillMigrationDebugInfo::BOOKMARK_ADDED: { | |
758 AutofillMigrationDebugInfo& debug_info = | |
759 kernel_->persisted_info.autofill_migration_debug_info; | |
760 TestAndSet<int>( | |
761 &debug_info.bookmarks_added_during_migration, | |
762 &info.bookmarks_added_during_migration); | |
763 break; | |
764 } | |
765 case AutofillMigrationDebugInfo::ENTRIES_ADDED: { | |
766 AutofillMigrationDebugInfo& debug_info = | |
767 kernel_->persisted_info.autofill_migration_debug_info; | |
768 TestAndSet<int>( | |
769 &debug_info.autofill_entries_added_during_migration, | |
770 &info.autofill_entries_added_during_migration); | |
771 break; | |
772 } | |
773 case AutofillMigrationDebugInfo::PROFILES_ADDED: { | |
774 AutofillMigrationDebugInfo& debug_info = | |
775 kernel_->persisted_info.autofill_migration_debug_info; | |
776 TestAndSet<int>( | |
777 &debug_info.autofill_profile_added_during_migration, | |
778 &info.autofill_profile_added_during_migration); | |
779 break; | |
780 } | |
781 default: | |
782 NOTREACHED(); | |
783 } | |
784 } | |
785 | |
786 void Directory::set_autofill_migration_state(AutofillMigrationState state) { | |
787 ScopedKernelLock lock(this); | |
788 if (state == kernel_->persisted_info.autofill_migration_state) { | |
789 return; | |
790 } | |
791 kernel_->persisted_info.autofill_migration_state = state; | |
792 if (state == MIGRATED) { | |
793 syncable::AutofillMigrationDebugInfo& debug_info = | |
794 kernel_->persisted_info.autofill_migration_debug_info; | |
tim (not reviewing)
2010/12/13 19:24:33
indent 4 spaces
lipalani
2010/12/14 21:05:57
Done.
| |
795 debug_info.autofill_migration_time = | |
796 base::Time::Now().ToInternalValue(); | |
tim (not reviewing)
2010/12/13 19:24:33
indent 4 spaces
lipalani
2010/12/14 21:05:57
Done.
| |
797 } | |
798 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY; | |
799 } | |
800 | |
723 void Directory::set_initial_sync_ended_for_type(ModelType type, bool x) { | 801 void Directory::set_initial_sync_ended_for_type(ModelType type, bool x) { |
724 ScopedKernelLock lock(this); | 802 ScopedKernelLock lock(this); |
725 set_initial_sync_ended_for_type_unsafe(type, x); | 803 set_initial_sync_ended_for_type_unsafe(type, x); |
726 } | 804 } |
727 | 805 |
728 void Directory::set_initial_sync_ended_for_type_unsafe(ModelType type, | 806 void Directory::set_initial_sync_ended_for_type_unsafe(ModelType type, |
729 bool x) { | 807 bool x) { |
730 if (kernel_->persisted_info.initial_sync_ended[type] == x) | 808 if (kernel_->persisted_info.initial_sync_ended[type] == x) |
731 return; | 809 return; |
732 kernel_->persisted_info.initial_sync_ended.set(type, x); | 810 kernel_->persisted_info.initial_sync_ended.set(type, x); |
(...skipping 919 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1652 | 1730 |
1653 FastDump& operator<<(FastDump& dump, const Blob& blob) { | 1731 FastDump& operator<<(FastDump& dump, const Blob& blob) { |
1654 if (blob.empty()) | 1732 if (blob.empty()) |
1655 return dump; | 1733 return dump; |
1656 string buffer(base::HexEncode(&blob[0], blob.size())); | 1734 string buffer(base::HexEncode(&blob[0], blob.size())); |
1657 dump.out_->sputn(buffer.c_str(), buffer.size()); | 1735 dump.out_->sputn(buffer.c_str(), buffer.size()); |
1658 return dump; | 1736 return dump; |
1659 } | 1737 } |
1660 | 1738 |
1661 } // namespace syncable | 1739 } // namespace syncable |
OLD | NEW |