OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_file_system/drive_backend/sync_engine.h" | 5 #include "chrome/browser/sync_file_system/drive_backend/sync_engine.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/metrics/histogram.h" |
10 #include "base/threading/sequenced_worker_pool.h" | 11 #include "base/threading/sequenced_worker_pool.h" |
| 12 #include "base/time/time.h" |
11 #include "base/values.h" | 13 #include "base/values.h" |
12 #include "chrome/browser/drive/drive_api_service.h" | 14 #include "chrome/browser/drive/drive_api_service.h" |
13 #include "chrome/browser/drive/drive_notification_manager.h" | 15 #include "chrome/browser/drive/drive_notification_manager.h" |
14 #include "chrome/browser/drive/drive_notification_manager_factory.h" | 16 #include "chrome/browser/drive/drive_notification_manager_factory.h" |
15 #include "chrome/browser/drive/drive_service_interface.h" | 17 #include "chrome/browser/drive/drive_service_interface.h" |
16 #include "chrome/browser/drive/drive_uploader.h" | 18 #include "chrome/browser/drive/drive_uploader.h" |
17 #include "chrome/browser/extensions/extension_service.h" | 19 #include "chrome/browser/extensions/extension_service.h" |
18 #include "chrome/browser/profiles/profile.h" | 20 #include "chrome/browser/profiles/profile.h" |
19 #include "chrome/browser/signin/profile_oauth2_token_service_factory.h" | 21 #include "chrome/browser/signin/profile_oauth2_token_service_factory.h" |
20 #include "chrome/browser/signin/signin_manager_factory.h" | 22 #include "chrome/browser/signin/signin_manager_factory.h" |
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
95 scoped_refptr<base::SequencedTaskRunner> ui_task_runner_; | 97 scoped_refptr<base::SequencedTaskRunner> ui_task_runner_; |
96 base::WeakPtr<SyncEngine> sync_engine_; | 98 base::WeakPtr<SyncEngine> sync_engine_; |
97 | 99 |
98 DISALLOW_COPY_AND_ASSIGN(WorkerObserver); | 100 DISALLOW_COPY_AND_ASSIGN(WorkerObserver); |
99 }; | 101 }; |
100 | 102 |
101 namespace { | 103 namespace { |
102 | 104 |
103 void EmptyStatusCallback(SyncStatusCode status) {} | 105 void EmptyStatusCallback(SyncStatusCode status) {} |
104 | 106 |
| 107 void DidRegisterOrigin(const base::TimeTicks& start_time, |
| 108 const SyncStatusCallback& callback, |
| 109 SyncStatusCode status) { |
| 110 base::TimeDelta delta(base::TimeTicks::Now() - start_time); |
| 111 HISTOGRAM_TIMES("SyncFileSystem.RegisterOriginTime", delta); |
| 112 callback.Run(status); |
| 113 } |
| 114 |
105 } // namespace | 115 } // namespace |
106 | 116 |
107 scoped_ptr<SyncEngine> SyncEngine::CreateForBrowserContext( | 117 scoped_ptr<SyncEngine> SyncEngine::CreateForBrowserContext( |
108 content::BrowserContext* context) { | 118 content::BrowserContext* context) { |
109 scoped_refptr<base::SequencedWorkerPool> worker_pool( | 119 scoped_refptr<base::SequencedWorkerPool> worker_pool( |
110 content::BrowserThread::GetBlockingPool()); | 120 content::BrowserThread::GetBlockingPool()); |
111 scoped_refptr<base::SequencedTaskRunner> drive_task_runner( | 121 scoped_refptr<base::SequencedTaskRunner> drive_task_runner( |
112 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( | 122 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( |
113 worker_pool->GetSequenceToken(), | 123 worker_pool->GetSequenceToken(), |
114 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN)); | 124 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN)); |
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
220 } | 230 } |
221 | 231 |
222 void SyncEngine::RegisterOrigin( | 232 void SyncEngine::RegisterOrigin( |
223 const GURL& origin, const SyncStatusCallback& callback) { | 233 const GURL& origin, const SyncStatusCallback& callback) { |
224 worker_task_runner_->PostTask( | 234 worker_task_runner_->PostTask( |
225 FROM_HERE, | 235 FROM_HERE, |
226 base::Bind(&SyncWorker::RegisterOrigin, | 236 base::Bind(&SyncWorker::RegisterOrigin, |
227 base::Unretained(sync_worker_.get()), | 237 base::Unretained(sync_worker_.get()), |
228 origin, | 238 origin, |
229 RelayCallbackToCurrentThread( | 239 RelayCallbackToCurrentThread( |
230 FROM_HERE, callback))); | 240 FROM_HERE, |
| 241 base::Bind(&DidRegisterOrigin, |
| 242 base::TimeTicks::Now(), |
| 243 callback)))); |
231 } | 244 } |
232 | 245 |
233 void SyncEngine::EnableOrigin( | 246 void SyncEngine::EnableOrigin( |
234 const GURL& origin, const SyncStatusCallback& callback) { | 247 const GURL& origin, const SyncStatusCallback& callback) { |
235 worker_task_runner_->PostTask( | 248 worker_task_runner_->PostTask( |
236 FROM_HERE, | 249 FROM_HERE, |
237 base::Bind(&SyncWorker::EnableOrigin, | 250 base::Bind(&SyncWorker::EnableOrigin, |
238 base::Unretained(sync_worker_.get()), | 251 base::Unretained(sync_worker_.get()), |
239 origin, | 252 origin, |
240 RelayCallbackToCurrentThread( | 253 RelayCallbackToCurrentThread( |
(...skipping 281 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
522 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; | 535 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; |
523 if (is_app_enabled && !is_app_root_tracker_enabled) | 536 if (is_app_enabled && !is_app_root_tracker_enabled) |
524 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 537 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
525 else if (!is_app_enabled && is_app_root_tracker_enabled) | 538 else if (!is_app_enabled && is_app_root_tracker_enabled) |
526 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 539 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
527 } | 540 } |
528 } | 541 } |
529 | 542 |
530 } // namespace drive_backend | 543 } // namespace drive_backend |
531 } // namespace sync_file_system | 544 } // namespace sync_file_system |
OLD | NEW |