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

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: Add chrome_version field; modify SyncUserAgent generation 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 "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 437 matching lines...) Expand 10 before | Expand all | Expand 10 after
654 model_type()); 635 model_type());
655 } 636 }
656 637
657 // Write the initial values to the specifics so that in case of a crash or 638 // Write the initial values to the specifics so that in case of a crash or
658 // error we don't persist a half-written node. 639 // error we don't persist a half-written node.
659 write_node.SetTitle(UTF8ToWide(current_machine_tag_)); 640 write_node.SetTitle(UTF8ToWide(current_machine_tag_));
660 sync_pb::SessionSpecifics base_specifics; 641 sync_pb::SessionSpecifics base_specifics;
661 base_specifics.set_session_tag(current_machine_tag_); 642 base_specifics.set_session_tag(current_machine_tag_);
662 sync_pb::SessionHeader* header_s = base_specifics.mutable_header(); 643 sync_pb::SessionHeader* header_s = base_specifics.mutable_header();
663 header_s->set_client_name(current_session_name_); 644 header_s->set_client_name(current_session_name_);
664 header_s->set_device_type(GetLocalDeviceType()); 645 header_s->set_device_type(DeviceInfo::GetLocalDeviceType());
665 write_node.SetSessionSpecifics(base_specifics); 646 write_node.SetSessionSpecifics(base_specifics);
666 647
667 local_session_syncid_ = write_node.GetId(); 648 local_session_syncid_ = write_node.GetId();
668 } 649 }
669 } 650 }
670 651
671 // Check if anything has changed on the client side. 652 // Check if anything has changed on the client side.
672 if (!UpdateSyncModelDataFromClient(&error)) { 653 if (!UpdateSyncModelDataFromClient(&error)) {
673 DCHECK(error.IsSet()); 654 DCHECK(error.IsSet());
674 return error; 655 return error;
(...skipping 305 matching lines...) Expand 10 before | Expand all | Expand 10 after
980 // Static 961 // Static
981 void SessionModelAssociator::PopulateSessionHeaderFromSpecifics( 962 void SessionModelAssociator::PopulateSessionHeaderFromSpecifics(
982 const sync_pb::SessionHeader& header_specifics, 963 const sync_pb::SessionHeader& header_specifics,
983 base::Time mtime, 964 base::Time mtime,
984 SyncedSession* session_header) { 965 SyncedSession* session_header) {
985 if (header_specifics.has_client_name()) { 966 if (header_specifics.has_client_name()) {
986 session_header->session_name = header_specifics.client_name(); 967 session_header->session_name = header_specifics.client_name();
987 } 968 }
988 if (header_specifics.has_device_type()) { 969 if (header_specifics.has_device_type()) {
989 switch (header_specifics.device_type()) { 970 switch (header_specifics.device_type()) {
990 case sync_pb::SessionHeader_DeviceType_TYPE_WIN: 971 case sync_pb::SyncEnums_DeviceType_TYPE_WIN:
991 session_header->device_type = SyncedSession::TYPE_WIN; 972 session_header->device_type = SyncedSession::TYPE_WIN;
992 break; 973 break;
993 case sync_pb::SessionHeader_DeviceType_TYPE_MAC: 974 case sync_pb::SyncEnums_DeviceType_TYPE_MAC:
994 session_header->device_type = SyncedSession::TYPE_MACOSX; 975 session_header->device_type = SyncedSession::TYPE_MACOSX;
995 break; 976 break;
996 case sync_pb::SessionHeader_DeviceType_TYPE_LINUX: 977 case sync_pb::SyncEnums_DeviceType_TYPE_LINUX:
997 session_header->device_type = SyncedSession::TYPE_LINUX; 978 session_header->device_type = SyncedSession::TYPE_LINUX;
998 break; 979 break;
999 case sync_pb::SessionHeader_DeviceType_TYPE_CROS: 980 case sync_pb::SyncEnums_DeviceType_TYPE_CROS:
1000 session_header->device_type = SyncedSession::TYPE_CHROMEOS; 981 session_header->device_type = SyncedSession::TYPE_CHROMEOS;
1001 break; 982 break;
1002 case sync_pb::SessionHeader_DeviceType_TYPE_PHONE: 983 case sync_pb::SyncEnums_DeviceType_TYPE_PHONE:
1003 session_header->device_type = SyncedSession::TYPE_PHONE; 984 session_header->device_type = SyncedSession::TYPE_PHONE;
1004 break; 985 break;
1005 case sync_pb::SessionHeader_DeviceType_TYPE_TABLET: 986 case sync_pb::SyncEnums_DeviceType_TYPE_TABLET:
1006 session_header->device_type = SyncedSession::TYPE_TABLET; 987 session_header->device_type = SyncedSession::TYPE_TABLET;
1007 break; 988 break;
1008 case sync_pb::SessionHeader_DeviceType_TYPE_OTHER: 989 case sync_pb::SyncEnums_DeviceType_TYPE_OTHER:
1009 // Intentionally fall-through 990 // Intentionally fall-through
1010 default: 991 default:
1011 session_header->device_type = SyncedSession::TYPE_OTHER; 992 session_header->device_type = SyncedSession::TYPE_OTHER;
1012 break; 993 break;
1013 } 994 }
1014 } 995 }
1015 session_header->modified_time = mtime; 996 session_header->modified_time = mtime;
1016 } 997 }
1017 998
1018 // Static 999 // Static
(...skipping 317 matching lines...) Expand 10 before | Expand all | Expand 10 after
1336 1317
1337 bool SessionModelAssociator::CryptoReadyIfNecessary() { 1318 bool SessionModelAssociator::CryptoReadyIfNecessary() {
1338 // We only access the cryptographer while holding a transaction. 1319 // We only access the cryptographer while holding a transaction.
1339 syncer::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); 1320 syncer::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare());
1340 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes(); 1321 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes();
1341 return !encrypted_types.Has(SESSIONS) || 1322 return !encrypted_types.Has(SESSIONS) ||
1342 sync_service_->IsCryptographerReady(&trans); 1323 sync_service_->IsCryptographerReady(&trans);
1343 } 1324 }
1344 1325
1345 } // namespace browser_sync 1326 } // namespace browser_sync
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698