| OLD | NEW |
| 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 <cstddef> | 5 #include <cstddef> |
| 6 #include <cstdio> | 6 #include <cstdio> |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/at_exit.h" | 9 #include "base/at_exit.h" |
| 10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
| 11 #include "base/compiler_specific.h" | 11 #include "base/compiler_specific.h" |
| 12 #include "base/debug/stack_trace.h" | 12 #include "base/debug/stack_trace.h" |
| 13 #include "base/files/scoped_temp_dir.h" | 13 #include "base/files/scoped_temp_dir.h" |
| 14 #include "base/json/json_writer.h" | 14 #include "base/json/json_writer.h" |
| 15 #include "base/logging.h" | 15 #include "base/logging.h" |
| 16 #include "base/memory/ref_counted.h" | 16 #include "base/memory/ref_counted.h" |
| 17 #include "base/memory/scoped_ptr.h" | 17 #include "base/memory/scoped_ptr.h" |
| 18 #include "base/memory/weak_ptr.h" | 18 #include "base/memory/weak_ptr.h" |
| 19 #include "base/message_loop/message_loop.h" | 19 #include "base/message_loop/message_loop.h" |
| 20 #include "base/rand_util.h" | 20 #include "base/rand_util.h" |
| 21 #include "base/task_runner.h" | 21 #include "base/task_runner.h" |
| 22 #include "base/threading/thread.h" | 22 #include "base/threading/thread.h" |
| 23 #include "jingle/notifier/base/notification_method.h" | 23 #include "jingle/notifier/base/notification_method.h" |
| 24 #include "jingle/notifier/base/notifier_options.h" | 24 #include "jingle/notifier/base/notifier_options.h" |
| 25 #include "net/base/host_port_pair.h" | 25 #include "net/base/host_port_pair.h" |
| 26 #include "net/base/network_change_notifier.h" | 26 #include "net/base/network_change_notifier.h" |
| 27 #include "net/dns/host_resolver.h" | 27 #include "net/dns/host_resolver.h" |
| 28 #include "net/http/transport_security_state.h" | 28 #include "net/http/transport_security_state.h" |
| 29 #include "net/url_request/url_request_test_util.h" | 29 #include "net/url_request/url_request_test_util.h" |
| 30 #include "sync/internal_api/public/base/cancelation_signal.h" | |
| 31 #include "sync/internal_api/public/base/model_type.h" | 30 #include "sync/internal_api/public/base/model_type.h" |
| 32 #include "sync/internal_api/public/base_node.h" | 31 #include "sync/internal_api/public/base_node.h" |
| 33 #include "sync/internal_api/public/engine/passive_model_worker.h" | 32 #include "sync/internal_api/public/engine/passive_model_worker.h" |
| 34 #include "sync/internal_api/public/http_bridge.h" | 33 #include "sync/internal_api/public/http_bridge.h" |
| 35 #include "sync/internal_api/public/internal_components_factory_impl.h" | 34 #include "sync/internal_api/public/internal_components_factory_impl.h" |
| 36 #include "sync/internal_api/public/read_node.h" | 35 #include "sync/internal_api/public/read_node.h" |
| 37 #include "sync/internal_api/public/sync_manager.h" | 36 #include "sync/internal_api/public/sync_manager.h" |
| 38 #include "sync/internal_api/public/sync_manager_factory.h" | 37 #include "sync/internal_api/public/sync_manager_factory.h" |
| 39 #include "sync/internal_api/public/util/report_unrecoverable_error_function.h" | 38 #include "sync/internal_api/public/util/report_unrecoverable_error_function.h" |
| 40 #include "sync/internal_api/public/util/unrecoverable_error_handler.h" | 39 #include "sync/internal_api/public/util/unrecoverable_error_handler.h" |
| (...skipping 302 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 343 // as NULL. | 342 // as NULL. |
| 344 ExtensionsActivity* extensions_activity = NULL; | 343 ExtensionsActivity* extensions_activity = NULL; |
| 345 LoggingChangeDelegate change_delegate; | 344 LoggingChangeDelegate change_delegate; |
| 346 const char kRestoredKeyForBootstrapping[] = ""; | 345 const char kRestoredKeyForBootstrapping[] = ""; |
| 347 const char kRestoredKeystoreKeyForBootstrapping[] = ""; | 346 const char kRestoredKeystoreKeyForBootstrapping[] = ""; |
| 348 NullEncryptor null_encryptor; | 347 NullEncryptor null_encryptor; |
| 349 InternalComponentsFactoryImpl::Switches factory_switches = { | 348 InternalComponentsFactoryImpl::Switches factory_switches = { |
| 350 InternalComponentsFactory::ENCRYPTION_KEYSTORE, | 349 InternalComponentsFactory::ENCRYPTION_KEYSTORE, |
| 351 InternalComponentsFactory::BACKOFF_NORMAL | 350 InternalComponentsFactory::BACKOFF_NORMAL |
| 352 }; | 351 }; |
| 353 CancelationSignal cancelation_signal; | |
| 354 | 352 |
| 355 sync_manager->Init(database_dir.path(), | 353 sync_manager->Init(database_dir.path(), |
| 356 WeakHandle<JsEventHandler>( | 354 WeakHandle<JsEventHandler>( |
| 357 js_event_handler.AsWeakPtr()), | 355 js_event_handler.AsWeakPtr()), |
| 358 kSyncServerAndPath, | 356 kSyncServerAndPath, |
| 359 kSyncServerPort, | 357 kSyncServerPort, |
| 360 kUseSsl, | 358 kUseSsl, |
| 361 post_factory.Pass(), | 359 post_factory.Pass(), |
| 362 workers, | 360 workers, |
| 363 extensions_activity, | 361 extensions_activity, |
| 364 &change_delegate, | 362 &change_delegate, |
| 365 credentials, | 363 credentials, |
| 366 invalidator_id, | 364 invalidator_id, |
| 367 kRestoredKeyForBootstrapping, | 365 kRestoredKeyForBootstrapping, |
| 368 kRestoredKeystoreKeyForBootstrapping, | 366 kRestoredKeystoreKeyForBootstrapping, |
| 369 new InternalComponentsFactoryImpl(factory_switches), | 367 new InternalComponentsFactoryImpl(factory_switches), |
| 370 &null_encryptor, | 368 &null_encryptor, |
| 371 scoped_ptr<UnrecoverableErrorHandler>( | 369 scoped_ptr<UnrecoverableErrorHandler>( |
| 372 new LoggingUnrecoverableErrorHandler).Pass(), | 370 new LoggingUnrecoverableErrorHandler).Pass(), |
| 373 &LogUnrecoverableErrorContext, false, | 371 &LogUnrecoverableErrorContext, false); |
| 374 &cancelation_signal); | |
| 375 // TODO(akalin): Avoid passing in model parameters multiple times by | 372 // TODO(akalin): Avoid passing in model parameters multiple times by |
| 376 // organizing handling of model types. | 373 // organizing handling of model types. |
| 377 invalidator->UpdateCredentials(credentials.email, credentials.sync_token); | 374 invalidator->UpdateCredentials(credentials.email, credentials.sync_token); |
| 378 invalidator->RegisterHandler(sync_manager.get()); | 375 invalidator->RegisterHandler(sync_manager.get()); |
| 379 invalidator->UpdateRegisteredIds( | 376 invalidator->UpdateRegisteredIds( |
| 380 sync_manager.get(), ModelTypeSetToObjectIdSet(model_types)); | 377 sync_manager.get(), ModelTypeSetToObjectIdSet(model_types)); |
| 381 sync_manager->StartSyncingNormally(routing_info); | 378 sync_manager->StartSyncingNormally(routing_info); |
| 382 | 379 |
| 383 sync_loop.Run(); | 380 sync_loop.Run(); |
| 384 | 381 |
| 385 io_thread.Stop(); | 382 io_thread.Stop(); |
| 386 return 0; | 383 return 0; |
| 387 } | 384 } |
| 388 | 385 |
| 389 } // namespace | 386 } // namespace |
| 390 } // namespace syncer | 387 } // namespace syncer |
| 391 | 388 |
| 392 int main(int argc, char* argv[]) { | 389 int main(int argc, char* argv[]) { |
| 393 return syncer::SyncClientMain(argc, argv); | 390 return syncer::SyncClientMain(argc, argv); |
| 394 } | 391 } |
| OLD | NEW |