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

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

Issue 10985008: sync: Add DeviceInfo protobuf and supporting code (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 3 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 "chrome/browser/sync/glue/session_model_associator.h" 5 #include "chrome/browser/sync/glue/session_model_associator.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <set> 8 #include <set>
9 #include <utility> 9 #include <utility>
10 10
11 #include "base/bind.h" 11 #include "base/bind.h"
12 #include "base/command_line.h" 12 #include "base/command_line.h"
13 #include "base/location.h" 13 #include "base/location.h"
14 #include "base/logging.h" 14 #include "base/logging.h"
15 #include "base/threading/sequenced_worker_pool.h" 15 #include "base/threading/sequenced_worker_pool.h"
16 #include "chrome/browser/favicon/favicon_service_factory.h" 16 #include "chrome/browser/favicon/favicon_service_factory.h"
17 #include "chrome/browser/history/history.h" 17 #include "chrome/browser/history/history.h"
18 #include "chrome/browser/prefs/pref_service.h" 18 #include "chrome/browser/prefs/pref_service.h"
19 #include "chrome/browser/profiles/profile.h" 19 #include "chrome/browser/profiles/profile.h"
20 #include "chrome/browser/sessions/session_id.h" 20 #include "chrome/browser/sessions/session_id.h"
21 #include "chrome/browser/sync/glue/device_info.h"
21 #include "chrome/browser/sync/glue/synced_session.h" 22 #include "chrome/browser/sync/glue/synced_session.h"
22 #include "chrome/browser/sync/glue/synced_tab_delegate.h" 23 #include "chrome/browser/sync/glue/synced_tab_delegate.h"
23 #include "chrome/browser/sync/glue/synced_window_delegate.h" 24 #include "chrome/browser/sync/glue/synced_window_delegate.h"
24 #include "chrome/browser/sync/profile_sync_service.h" 25 #include "chrome/browser/sync/profile_sync_service.h"
25 #include "chrome/common/chrome_notification_types.h" 26 #include "chrome/common/chrome_notification_types.h"
26 #include "chrome/common/chrome_switches.h" 27 #include "chrome/common/chrome_switches.h"
27 #include "chrome/common/pref_names.h" 28 #include "chrome/common/pref_names.h"
28 #include "chrome/common/url_constants.h" 29 #include "chrome/common/url_constants.h"
29 #include "content/public/browser/navigation_entry.h" 30 #include "content/public/browser/navigation_entry.h"
30 #include "content/public/browser/notification_details.h" 31 #include "content/public/browser/notification_details.h"
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
69 // Default number of days without activity after which a session is considered 70 // Default number of days without activity after which a session is considered
70 // stale and becomes a candidate for garbage collection. 71 // stale and becomes a candidate for garbage collection.
71 static const size_t kDefaultStaleSessionThresholdDays = 14; // 2 weeks. 72 static const size_t kDefaultStaleSessionThresholdDays = 14; // 2 weeks.
72 73
73 #if defined(OS_ANDROID) 74 #if defined(OS_ANDROID)
74 bool IsTabletUI() { 75 bool IsTabletUI() {
75 return CommandLine::ForCurrentProcess()->HasSwitch(switches::kTabletUI); 76 return CommandLine::ForCurrentProcess()->HasSwitch(switches::kTabletUI);
76 } 77 }
77 #endif 78 #endif
78 79
79 sync_pb::SessionHeader::DeviceType GetLocalDeviceType() {
80 // TODO(yfriedman): Refactor/combine with "DeviceInformation" code in
81 // sync_manager.cc[1060]
82 #if defined(OS_CHROMEOS)
83 return sync_pb::SessionHeader_DeviceType_TYPE_CROS;
84 #elif defined(OS_LINUX)
85 return sync_pb::SessionHeader_DeviceType_TYPE_LINUX;
86 #elif defined(OS_MACOSX)
87 return sync_pb::SessionHeader_DeviceType_TYPE_MAC;
88 #elif defined(OS_WIN)
89 return sync_pb::SessionHeader_DeviceType_TYPE_WIN;
90 #elif defined(OS_ANDROID)
91 return IsTabletUI() ?
92 sync_pb::SessionHeader_DeviceType_TYPE_TABLET :
93 sync_pb::SessionHeader_DeviceType_TYPE_PHONE;
94 #else
95 return sync_pb::SessionHeader_DeviceType_TYPE_OTHER;
96 #endif
97 }
98
99 } // namespace 80 } // namespace
100 81
101 SessionModelAssociator::SessionModelAssociator(ProfileSyncService* sync_service, 82 SessionModelAssociator::SessionModelAssociator(ProfileSyncService* sync_service,
102 DataTypeErrorHandler* error_handler) 83 DataTypeErrorHandler* error_handler)
103 : tab_pool_(sync_service), 84 : tab_pool_(sync_service),
104 local_session_syncid_(syncer::kInvalidId), 85 local_session_syncid_(syncer::kInvalidId),
105 sync_service_(sync_service), 86 sync_service_(sync_service),
106 stale_session_threshold_days_(kDefaultStaleSessionThresholdDays), 87 stale_session_threshold_days_(kDefaultStaleSessionThresholdDays),
107 setup_for_test_(false), 88 setup_for_test_(false),
108 waiting_for_change_(false), 89 waiting_for_change_(false),
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
196 syncer::SyncError* error) { 177 syncer::SyncError* error) {
197 DCHECK(CalledOnValidThread()); 178 DCHECK(CalledOnValidThread());
198 std::string local_tag = GetCurrentMachineTag(); 179 std::string local_tag = GetCurrentMachineTag();
199 sync_pb::SessionSpecifics specifics; 180 sync_pb::SessionSpecifics specifics;
200 specifics.set_session_tag(local_tag); 181 specifics.set_session_tag(local_tag);
201 sync_pb::SessionHeader* header_s = specifics.mutable_header(); 182 sync_pb::SessionHeader* header_s = specifics.mutable_header();
202 SyncedSession* current_session = 183 SyncedSession* current_session =
203 synced_session_tracker_.GetSession(local_tag); 184 synced_session_tracker_.GetSession(local_tag);
204 current_session->modified_time = base::Time::Now(); 185 current_session->modified_time = base::Time::Now();
205 header_s->set_client_name(current_session_name_); 186 header_s->set_client_name(current_session_name_);
206 header_s->set_device_type(GetLocalDeviceType()); 187 header_s->set_device_type(DeviceInfo::GetLocalDeviceType());
207 188
208 synced_session_tracker_.ResetSessionTracking(local_tag); 189 synced_session_tracker_.ResetSessionTracking(local_tag);
209 std::set<SyncedWindowDelegate*> windows = 190 std::set<SyncedWindowDelegate*> windows =
210 SyncedWindowDelegate::GetSyncedWindowDelegates(); 191 SyncedWindowDelegate::GetSyncedWindowDelegates();
211 for (std::set<SyncedWindowDelegate*>::const_iterator i = 192 for (std::set<SyncedWindowDelegate*>::const_iterator i =
212 windows.begin(); i != windows.end(); ++i) { 193 windows.begin(); i != windows.end(); ++i) {
213 // Make sure the window has tabs and a viewable window. The viewable window 194 // Make sure the window has tabs and a viewable window. The viewable window
214 // check is necessary because, for example, when a browser is closed the 195 // check is necessary because, for example, when a browser is closed the
215 // destructor is not necessarily run immediately. This means its possible 196 // destructor is not necessarily run immediately. This means its possible
216 // for us to get a handle to a browser that is about to be removed. If 197 // for us to get a handle to a browser that is about to be removed. If
(...skipping 495 matching lines...) Expand 10 before | Expand all | Expand 10 after
712 model_type()); 693 model_type());
713 } 694 }
714 695
715 // Write the initial values to the specifics so that in case of a crash or 696 // Write the initial values to the specifics so that in case of a crash or
716 // error we don't persist a half-written node. 697 // error we don't persist a half-written node.
717 write_node.SetTitle(UTF8ToWide(current_machine_tag_)); 698 write_node.SetTitle(UTF8ToWide(current_machine_tag_));
718 sync_pb::SessionSpecifics base_specifics; 699 sync_pb::SessionSpecifics base_specifics;
719 base_specifics.set_session_tag(current_machine_tag_); 700 base_specifics.set_session_tag(current_machine_tag_);
720 sync_pb::SessionHeader* header_s = base_specifics.mutable_header(); 701 sync_pb::SessionHeader* header_s = base_specifics.mutable_header();
721 header_s->set_client_name(current_session_name_); 702 header_s->set_client_name(current_session_name_);
722 header_s->set_device_type(GetLocalDeviceType()); 703 header_s->set_device_type(DeviceInfo::GetLocalDeviceType());
723 write_node.SetSessionSpecifics(base_specifics); 704 write_node.SetSessionSpecifics(base_specifics);
724 705
725 local_session_syncid_ = write_node.GetId(); 706 local_session_syncid_ = write_node.GetId();
726 } 707 }
727 } 708 }
728 709
729 // Check if anything has changed on the client side. 710 // Check if anything has changed on the client side.
730 if (!UpdateSyncModelDataFromClient(&error)) { 711 if (!UpdateSyncModelDataFromClient(&error)) {
731 DCHECK(error.IsSet()); 712 DCHECK(error.IsSet());
732 return error; 713 return error;
(...skipping 305 matching lines...) Expand 10 before | Expand all | Expand 10 after
1038 // Static 1019 // Static
1039 void SessionModelAssociator::PopulateSessionHeaderFromSpecifics( 1020 void SessionModelAssociator::PopulateSessionHeaderFromSpecifics(
1040 const sync_pb::SessionHeader& header_specifics, 1021 const sync_pb::SessionHeader& header_specifics,
1041 const base::Time& mtime, 1022 const base::Time& mtime,
1042 SyncedSession* session_header) { 1023 SyncedSession* session_header) {
1043 if (header_specifics.has_client_name()) { 1024 if (header_specifics.has_client_name()) {
1044 session_header->session_name = header_specifics.client_name(); 1025 session_header->session_name = header_specifics.client_name();
1045 } 1026 }
1046 if (header_specifics.has_device_type()) { 1027 if (header_specifics.has_device_type()) {
1047 switch (header_specifics.device_type()) { 1028 switch (header_specifics.device_type()) {
1048 case sync_pb::SessionHeader_DeviceType_TYPE_WIN: 1029 case sync_pb::SyncEnums_DeviceType_TYPE_WIN:
1049 session_header->device_type = SyncedSession::TYPE_WIN; 1030 session_header->device_type = SyncedSession::TYPE_WIN;
1050 break; 1031 break;
1051 case sync_pb::SessionHeader_DeviceType_TYPE_MAC: 1032 case sync_pb::SyncEnums_DeviceType_TYPE_MAC:
1052 session_header->device_type = SyncedSession::TYPE_MACOSX; 1033 session_header->device_type = SyncedSession::TYPE_MACOSX;
1053 break; 1034 break;
1054 case sync_pb::SessionHeader_DeviceType_TYPE_LINUX: 1035 case sync_pb::SyncEnums_DeviceType_TYPE_LINUX:
1055 session_header->device_type = SyncedSession::TYPE_LINUX; 1036 session_header->device_type = SyncedSession::TYPE_LINUX;
1056 break; 1037 break;
1057 case sync_pb::SessionHeader_DeviceType_TYPE_CROS: 1038 case sync_pb::SyncEnums_DeviceType_TYPE_CROS:
1058 session_header->device_type = SyncedSession::TYPE_CHROMEOS; 1039 session_header->device_type = SyncedSession::TYPE_CHROMEOS;
1059 break; 1040 break;
1060 case sync_pb::SessionHeader_DeviceType_TYPE_PHONE: 1041 case sync_pb::SyncEnums_DeviceType_TYPE_PHONE:
1061 session_header->device_type = SyncedSession::TYPE_PHONE; 1042 session_header->device_type = SyncedSession::TYPE_PHONE;
1062 break; 1043 break;
1063 case sync_pb::SessionHeader_DeviceType_TYPE_TABLET: 1044 case sync_pb::SyncEnums_DeviceType_TYPE_TABLET:
1064 session_header->device_type = SyncedSession::TYPE_TABLET; 1045 session_header->device_type = SyncedSession::TYPE_TABLET;
1065 break; 1046 break;
1066 case sync_pb::SessionHeader_DeviceType_TYPE_OTHER: 1047 case sync_pb::SyncEnums_DeviceType_TYPE_OTHER:
1067 // Intentionally fall-through 1048 // Intentionally fall-through
1068 default: 1049 default:
1069 session_header->device_type = SyncedSession::TYPE_OTHER; 1050 session_header->device_type = SyncedSession::TYPE_OTHER;
1070 break; 1051 break;
1071 } 1052 }
1072 } 1053 }
1073 session_header->modified_time = mtime; 1054 session_header->modified_time = mtime;
1074 } 1055 }
1075 1056
1076 // Static 1057 // Static
(...skipping 344 matching lines...) Expand 10 before | Expand all | Expand 10 after
1421 1402
1422 bool SessionModelAssociator::CryptoReadyIfNecessary() { 1403 bool SessionModelAssociator::CryptoReadyIfNecessary() {
1423 // We only access the cryptographer while holding a transaction. 1404 // We only access the cryptographer while holding a transaction.
1424 syncer::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); 1405 syncer::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare());
1425 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes(); 1406 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes();
1426 return !encrypted_types.Has(SESSIONS) || 1407 return !encrypted_types.Has(SESSIONS) ||
1427 sync_service_->IsCryptographerReady(&trans); 1408 sync_service_->IsCryptographerReady(&trans);
1428 } 1409 }
1429 1410
1430 } // namespace browser_sync 1411 } // namespace browser_sync
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698