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

Side by Side Diff: components/invalidation/ticl_invalidation_service.cc

Issue 319223002: Componentize TiclInvalidationService (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 6 years, 6 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) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 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/invalidation/ticl_invalidation_service.h" 5 #include "components/invalidation/ticl_invalidation_service.h"
6 6
7 #include "base/command_line.h" 7 #include "base/command_line.h"
8 #include "base/metrics/histogram.h" 8 #include "base/metrics/histogram.h"
9 #include "chrome/browser/invalidation/gcm_invalidation_bridge.h"
10 #include "chrome/common/chrome_content_client.h"
11 #include "components/gcm_driver/gcm_driver.h" 9 #include "components/gcm_driver/gcm_driver.h"
10 #include "components/invalidation/gcm_invalidation_bridge.h"
12 #include "components/invalidation/invalidation_service_util.h" 11 #include "components/invalidation/invalidation_service_util.h"
13 #include "components/invalidation/non_blocking_invalidator.h" 12 #include "components/invalidation/non_blocking_invalidator.h"
14 #include "google_apis/gaia/gaia_constants.h" 13 #include "google_apis/gaia/gaia_constants.h"
15 #include "net/url_request/url_request_context_getter.h" 14 #include "net/url_request/url_request_context_getter.h"
16 #include "sync/internal_api/public/base/invalidator_state.h" 15 #include "sync/internal_api/public/base/invalidator_state.h"
17 #include "sync/notifier/invalidation_util.h" 16 #include "sync/notifier/invalidation_util.h"
18 #include "sync/notifier/invalidator.h" 17 #include "sync/notifier/invalidator.h"
19 #include "sync/notifier/object_id_invalidation_map.h" 18 #include "sync/notifier/object_id_invalidation_map.h"
20 19
21 static const char* kOAuth2Scopes[] = { 20 static const char* kOAuth2Scopes[] = {
(...skipping 24 matching lines...) Expand all
46 // has no significant state, -1 to never discard. 45 // has no significant state, -1 to never discard.
47 -1, 46 -1,
48 47
49 // Don't use initial delay unless the last request was an error. 48 // Don't use initial delay unless the last request was an error.
50 false, 49 false,
51 }; 50 };
52 51
53 namespace invalidation { 52 namespace invalidation {
54 53
55 TiclInvalidationService::TiclInvalidationService( 54 TiclInvalidationService::TiclInvalidationService(
55 const std::string& user_agent,
56 scoped_ptr<IdentityProvider> identity_provider, 56 scoped_ptr<IdentityProvider> identity_provider,
57 scoped_ptr<TiclSettingsProvider> settings_provider, 57 scoped_ptr<TiclSettingsProvider> settings_provider,
58 gcm::GCMDriver* gcm_driver, 58 gcm::GCMDriver* gcm_driver,
59 const scoped_refptr<net::URLRequestContextGetter>& request_context) 59 const scoped_refptr<net::URLRequestContextGetter>& request_context)
60 : OAuth2TokenService::Consumer("ticl_invalidation"), 60 : OAuth2TokenService::Consumer("ticl_invalidation"),
61 user_agent_(user_agent),
61 identity_provider_(identity_provider.Pass()), 62 identity_provider_(identity_provider.Pass()),
62 settings_provider_(settings_provider.Pass()), 63 settings_provider_(settings_provider.Pass()),
63 invalidator_registrar_(new syncer::InvalidatorRegistrar()), 64 invalidator_registrar_(new syncer::InvalidatorRegistrar()),
64 request_access_token_backoff_(&kRequestAccessTokenBackoffPolicy), 65 request_access_token_backoff_(&kRequestAccessTokenBackoffPolicy),
65 network_channel_type_(PUSH_CLIENT_CHANNEL), 66 network_channel_type_(PUSH_CLIENT_CHANNEL),
66 gcm_driver_(gcm_driver), 67 gcm_driver_(gcm_driver),
67 request_context_(request_context), 68 request_context_(request_context),
68 logger_() {} 69 logger_() {}
69 70
70 TiclInvalidationService::~TiclInvalidationService() { 71 TiclInvalidationService::~TiclInvalidationService() {
(...skipping 314 matching lines...) Expand 10 before | Expand all | Expand 10 after
385 } 386 }
386 387
387 UMA_HISTOGRAM_ENUMERATION( 388 UMA_HISTOGRAM_ENUMERATION(
388 "Invalidations.NetworkChannel", network_channel, NETWORK_CHANNELS_COUNT); 389 "Invalidations.NetworkChannel", network_channel, NETWORK_CHANNELS_COUNT);
389 invalidator_.reset(new syncer::NonBlockingInvalidator( 390 invalidator_.reset(new syncer::NonBlockingInvalidator(
390 network_channel_creator, 391 network_channel_creator,
391 invalidation_state_tracker_->GetInvalidatorClientId(), 392 invalidation_state_tracker_->GetInvalidatorClientId(),
392 invalidation_state_tracker_->GetSavedInvalidations(), 393 invalidation_state_tracker_->GetSavedInvalidations(),
393 invalidation_state_tracker_->GetBootstrapData(), 394 invalidation_state_tracker_->GetBootstrapData(),
394 invalidation_state_tracker_.get(), 395 invalidation_state_tracker_.get(),
395 GetUserAgent(), 396 user_agent_,
396 request_context_)); 397 request_context_));
397 398
398 UpdateInvalidatorCredentials(); 399 UpdateInvalidatorCredentials();
399 400
400 invalidator_->RegisterHandler(this); 401 invalidator_->RegisterHandler(this);
401 invalidator_->UpdateRegisteredIds( 402 invalidator_->UpdateRegisteredIds(
402 this, 403 this,
403 invalidator_registrar_->GetAllRegisteredIds()); 404 invalidator_registrar_->GetAllRegisteredIds());
404 } 405 }
405 406
(...skipping 20 matching lines...) Expand all
426 } 427 }
427 428
428 void TiclInvalidationService::StopInvalidator() { 429 void TiclInvalidationService::StopInvalidator() {
429 DCHECK(invalidator_); 430 DCHECK(invalidator_);
430 gcm_invalidation_bridge_.reset(); 431 gcm_invalidation_bridge_.reset();
431 invalidator_->UnregisterHandler(this); 432 invalidator_->UnregisterHandler(this);
432 invalidator_.reset(); 433 invalidator_.reset();
433 } 434 }
434 435
435 } // namespace invalidation 436 } // namespace invalidation
OLDNEW
« no previous file with comments | « components/invalidation/ticl_invalidation_service.h ('k') | components/invalidation/ticl_invalidation_service_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698