| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 |
| OLD | NEW |