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

Side by Side Diff: sync/internal_api/sync_manager_impl.cc

Issue 217633003: sync: Remove TrafficRecorder (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 9 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 "sync/internal_api/sync_manager_impl.h" 5 #include "sync/internal_api/sync_manager_impl.h"
6 6
7 #include <string> 7 #include <string>
8 8
9 #include "base/base64.h" 9 #include "base/base64.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after
58 using syncable::UNIQUE_POSITION; 58 using syncable::UNIQUE_POSITION;
59 59
60 namespace { 60 namespace {
61 61
62 // Delays for syncer nudges. 62 // Delays for syncer nudges.
63 static const int kDefaultNudgeDelayMilliseconds = 200; 63 static const int kDefaultNudgeDelayMilliseconds = 200;
64 static const int kPreferencesNudgeDelayMilliseconds = 2000; 64 static const int kPreferencesNudgeDelayMilliseconds = 2000;
65 static const int kSyncRefreshDelayMsec = 500; 65 static const int kSyncRefreshDelayMsec = 500;
66 static const int kSyncSchedulerDelayMsec = 250; 66 static const int kSyncSchedulerDelayMsec = 250;
67 67
68 // Maximum count and size for traffic recorder.
69 static const unsigned int kMaxMessagesToRecord = 100;
70 static const unsigned int kMaxMessageSizeToRecord = 50 * 1024;
71
72 GetUpdatesCallerInfo::GetUpdatesSource GetSourceFromReason( 68 GetUpdatesCallerInfo::GetUpdatesSource GetSourceFromReason(
73 ConfigureReason reason) { 69 ConfigureReason reason) {
74 switch (reason) { 70 switch (reason) {
75 case CONFIGURE_REASON_RECONFIGURATION: 71 case CONFIGURE_REASON_RECONFIGURATION:
76 return GetUpdatesCallerInfo::RECONFIGURATION; 72 return GetUpdatesCallerInfo::RECONFIGURATION;
77 case CONFIGURE_REASON_MIGRATION: 73 case CONFIGURE_REASON_MIGRATION:
78 return GetUpdatesCallerInfo::MIGRATION; 74 return GetUpdatesCallerInfo::MIGRATION;
79 case CONFIGURE_REASON_NEW_CLIENT: 75 case CONFIGURE_REASON_NEW_CLIENT:
80 return GetUpdatesCallerInfo::NEW_CLIENT; 76 return GetUpdatesCallerInfo::NEW_CLIENT;
81 case CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE: 77 case CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE:
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
165 return delay; 161 return delay;
166 } 162 }
167 }; 163 };
168 164
169 SyncManagerImpl::SyncManagerImpl(const std::string& name) 165 SyncManagerImpl::SyncManagerImpl(const std::string& name)
170 : name_(name), 166 : name_(name),
171 change_delegate_(NULL), 167 change_delegate_(NULL),
172 initialized_(false), 168 initialized_(false),
173 observing_network_connectivity_changes_(false), 169 observing_network_connectivity_changes_(false),
174 invalidator_state_(DEFAULT_INVALIDATION_ERROR), 170 invalidator_state_(DEFAULT_INVALIDATION_ERROR),
175 traffic_recorder_(kMaxMessagesToRecord, kMaxMessageSizeToRecord),
176 encryptor_(NULL), 171 encryptor_(NULL),
177 report_unrecoverable_error_function_(NULL), 172 report_unrecoverable_error_function_(NULL),
178 weak_ptr_factory_(this) { 173 weak_ptr_factory_(this) {
179 // Pre-fill |notification_info_map_|. 174 // Pre-fill |notification_info_map_|.
180 for (int i = FIRST_REAL_MODEL_TYPE; i < MODEL_TYPE_COUNT; ++i) { 175 for (int i = FIRST_REAL_MODEL_TYPE; i < MODEL_TYPE_COUNT; ++i) {
181 notification_info_map_.insert( 176 notification_info_map_.insert(
182 std::make_pair(ModelTypeFromInt(i), NotificationInfo())); 177 std::make_pair(ModelTypeFromInt(i), NotificationInfo()));
183 } 178 }
184 179
185 // Bind message handlers. 180 // Bind message handlers.
186 BindJsMessageHandler( 181 BindJsMessageHandler(
187 "getAllNodes", 182 "getAllNodes",
188 &SyncManagerImpl::GetAllNodes); 183 &SyncManagerImpl::GetAllNodes);
189 BindJsMessageHandler(
190 "getClientServerTraffic",
191 &SyncManagerImpl::GetClientServerTraffic);
192 } 184 }
193 185
194 SyncManagerImpl::~SyncManagerImpl() { 186 SyncManagerImpl::~SyncManagerImpl() {
195 DCHECK(thread_checker_.CalledOnValidThread()); 187 DCHECK(thread_checker_.CalledOnValidThread());
196 CHECK(!initialized_); 188 CHECK(!initialized_);
197 } 189 }
198 190
199 SyncManagerImpl::NotificationInfo::NotificationInfo() : total_count(0) {} 191 SyncManagerImpl::NotificationInfo::NotificationInfo() : total_count(0) {}
200 SyncManagerImpl::NotificationInfo::~NotificationInfo() {} 192 SyncManagerImpl::NotificationInfo::~NotificationInfo() {}
201 193
(...skipping 215 matching lines...) Expand 10 before | Expand all | Expand 10 after
417 DVLOG(1) << "Sync is bringing up SyncSessionContext."; 409 DVLOG(1) << "Sync is bringing up SyncSessionContext.";
418 std::vector<SyncEngineEventListener*> listeners; 410 std::vector<SyncEngineEventListener*> listeners;
419 listeners.push_back(&allstatus_); 411 listeners.push_back(&allstatus_);
420 listeners.push_back(this); 412 listeners.push_back(this);
421 session_context_ = internal_components_factory->BuildContext( 413 session_context_ = internal_components_factory->BuildContext(
422 connection_manager_.get(), 414 connection_manager_.get(),
423 directory(), 415 directory(),
424 extensions_activity, 416 extensions_activity,
425 listeners, 417 listeners,
426 &debug_info_event_listener_, 418 &debug_info_event_listener_,
427 &traffic_recorder_,
428 model_type_registry_.get(), 419 model_type_registry_.get(),
429 invalidator_client_id).Pass(); 420 invalidator_client_id).Pass();
430 session_context_->set_account_name(credentials.email); 421 session_context_->set_account_name(credentials.email);
431 scheduler_ = internal_components_factory->BuildScheduler( 422 scheduler_ = internal_components_factory->BuildScheduler(
432 name_, session_context_.get(), cancelation_signal).Pass(); 423 name_, session_context_.get(), cancelation_signal).Pass();
433 424
434 scheduler_->Start(SyncScheduler::CONFIGURATION_MODE); 425 scheduler_->Start(SyncScheduler::CONFIGURATION_MODE);
435 426
436 initialized_ = true; 427 initialized_ = true;
437 428
(...skipping 545 matching lines...) Expand 10 before | Expand all | Expand 10 after
983 name, js_message_handler.Run(args)); 974 name, js_message_handler.Run(args));
984 } 975 }
985 976
986 void SyncManagerImpl::BindJsMessageHandler( 977 void SyncManagerImpl::BindJsMessageHandler(
987 const std::string& name, 978 const std::string& name,
988 UnboundJsMessageHandler unbound_message_handler) { 979 UnboundJsMessageHandler unbound_message_handler) {
989 js_message_handlers_[name] = 980 js_message_handlers_[name] =
990 base::Bind(unbound_message_handler, base::Unretained(this)); 981 base::Bind(unbound_message_handler, base::Unretained(this));
991 } 982 }
992 983
993 JsArgList SyncManagerImpl::GetClientServerTraffic(
994 const JsArgList& args) {
995 base::ListValue return_args;
996 base::ListValue* value = traffic_recorder_.ToValue();
997 if (value != NULL)
998 return_args.Append(value);
999 return JsArgList(&return_args);
1000 }
1001
1002 JsArgList SyncManagerImpl::GetAllNodes(const JsArgList& args) { 984 JsArgList SyncManagerImpl::GetAllNodes(const JsArgList& args) {
1003 ReadTransaction trans(FROM_HERE, GetUserShare()); 985 ReadTransaction trans(FROM_HERE, GetUserShare());
1004 base::ListValue return_args; 986 base::ListValue return_args;
1005 scoped_ptr<base::ListValue> nodes( 987 scoped_ptr<base::ListValue> nodes(
1006 trans.GetDirectory()->GetAllNodeDetails(trans.GetWrappedTrans())); 988 trans.GetDirectory()->GetAllNodeDetails(trans.GetWrappedTrans()));
1007 return_args.Append(nodes.release()); 989 return_args.Append(nodes.release());
1008 return JsArgList(&return_args); 990 return JsArgList(&return_args);
1009 } 991 }
1010 992
1011 void SyncManagerImpl::OnInvalidatorStateChange(InvalidatorState state) { 993 void SyncManagerImpl::OnInvalidatorStateChange(InvalidatorState state) {
(...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after
1165 int SyncManagerImpl::GetDefaultNudgeDelay() { 1147 int SyncManagerImpl::GetDefaultNudgeDelay() {
1166 return kDefaultNudgeDelayMilliseconds; 1148 return kDefaultNudgeDelayMilliseconds;
1167 } 1149 }
1168 1150
1169 // static. 1151 // static.
1170 int SyncManagerImpl::GetPreferencesNudgeDelay() { 1152 int SyncManagerImpl::GetPreferencesNudgeDelay() {
1171 return kPreferencesNudgeDelayMilliseconds; 1153 return kPreferencesNudgeDelayMilliseconds;
1172 } 1154 }
1173 1155
1174 } // namespace syncer 1156 } // namespace syncer
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698