| Index: trunk/src/sync/internal_api/sync_manager_impl.cc
|
| ===================================================================
|
| --- trunk/src/sync/internal_api/sync_manager_impl.cc (revision 222204)
|
| +++ trunk/src/sync/internal_api/sync_manager_impl.cc (working copy)
|
| @@ -19,7 +19,6 @@
|
| #include "sync/engine/sync_scheduler.h"
|
| #include "sync/engine/syncer_types.h"
|
| #include "sync/internal_api/change_reorder_buffer.h"
|
| -#include "sync/internal_api/public/base/cancelation_signal.h"
|
| #include "sync/internal_api/public/base/model_type.h"
|
| #include "sync/internal_api/public/base_node.h"
|
| #include "sync/internal_api/public/configure_reason.h"
|
| @@ -355,14 +354,12 @@
|
| Encryptor* encryptor,
|
| scoped_ptr<UnrecoverableErrorHandler> unrecoverable_error_handler,
|
| ReportUnrecoverableErrorFunction report_unrecoverable_error_function,
|
| - bool use_oauth2_token,
|
| - CancelationSignal* cancelation_signal) {
|
| + bool use_oauth2_token) {
|
| CHECK(!initialized_);
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| DCHECK(post_factory.get());
|
| DCHECK(!credentials.email.empty());
|
| DCHECK(!credentials.sync_token.empty());
|
| - DCHECK(cancelation_signal);
|
| DVLOG(1) << "SyncManager starting Init...";
|
|
|
| weak_handle_this_ = MakeWeakHandle(weak_ptr_factory_.GetWeakPtr());
|
| @@ -422,7 +419,7 @@
|
|
|
| connection_manager_.reset(new SyncAPIServerConnectionManager(
|
| sync_server_and_path, port, use_ssl, use_oauth2_token,
|
| - post_factory.release(), cancelation_signal));
|
| + post_factory.release()));
|
| connection_manager_->set_client_id(directory()->cache_guid());
|
| connection_manager_->AddListener(this);
|
|
|
| @@ -450,7 +447,7 @@
|
| invalidator_client_id).Pass();
|
| session_context_->set_account_name(credentials.email);
|
| scheduler_ = internal_components_factory->BuildScheduler(
|
| - name_, session_context_.get(), cancelation_signal).Pass();
|
| + name_, session_context_.get()).Pass();
|
|
|
| scheduler_->Start(SyncScheduler::CONFIGURATION_MODE);
|
|
|
| @@ -621,6 +618,13 @@
|
| observers_.RemoveObserver(observer);
|
| }
|
|
|
| +void SyncManagerImpl::StopSyncingForShutdown() {
|
| + DVLOG(2) << "StopSyncingForShutdown";
|
| + scheduler_->RequestStop();
|
| + if (connection_manager_)
|
| + connection_manager_->TerminateAllIO();
|
| +}
|
| +
|
| void SyncManagerImpl::ShutdownOnSyncThread() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
|
|
|
|