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

Side by Side Diff: sync/tools/sync_client.cc

Issue 14046031: Worker changes to prepare for lock-free shutdown. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 7 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
« no previous file with comments | « sync/test/engine/fake_model_worker.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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"
(...skipping 275 matching lines...) Expand 10 before | Expand all | Expand 10 after
286 CHECK(database_dir.CreateUniqueTempDir()); 286 CHECK(database_dir.CreateUniqueTempDir());
287 287
288 // Set up model type parameters. 288 // Set up model type parameters.
289 const ModelTypeSet model_types = ModelTypeSet::All(); 289 const ModelTypeSet model_types = ModelTypeSet::All();
290 ModelSafeRoutingInfo routing_info; 290 ModelSafeRoutingInfo routing_info;
291 for (ModelTypeSet::Iterator it = model_types.First(); 291 for (ModelTypeSet::Iterator it = model_types.First();
292 it.Good(); it.Inc()) { 292 it.Good(); it.Inc()) {
293 routing_info[it.Get()] = GROUP_PASSIVE; 293 routing_info[it.Get()] = GROUP_PASSIVE;
294 } 294 }
295 scoped_refptr<PassiveModelWorker> passive_model_safe_worker = 295 scoped_refptr<PassiveModelWorker> passive_model_safe_worker =
296 new PassiveModelWorker(&sync_loop); 296 new PassiveModelWorker(&sync_loop, NULL);
297 std::vector<ModelSafeWorker*> workers; 297 std::vector<ModelSafeWorker*> workers;
298 workers.push_back(passive_model_safe_worker.get()); 298 workers.push_back(passive_model_safe_worker.get());
299 299
300 // Set up sync manager. 300 // Set up sync manager.
301 SyncManagerFactory sync_manager_factory; 301 SyncManagerFactory sync_manager_factory;
302 scoped_ptr<SyncManager> sync_manager = 302 scoped_ptr<SyncManager> sync_manager =
303 sync_manager_factory.CreateSyncManager("sync_client manager"); 303 sync_manager_factory.CreateSyncManager("sync_client manager");
304 LoggingJsEventHandler js_event_handler; 304 LoggingJsEventHandler js_event_handler;
305 const char kSyncServerAndPath[] = "clients4.google.com/chrome-sync/dev"; 305 const char kSyncServerAndPath[] = "clients4.google.com/chrome-sync/dev";
306 int kSyncServerPort = 443; 306 int kSyncServerPort = 443;
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
358 io_thread.Stop(); 358 io_thread.Stop();
359 return 0; 359 return 0;
360 } 360 }
361 361
362 } // namespace 362 } // namespace
363 } // namespace syncer 363 } // namespace syncer
364 364
365 int main(int argc, char* argv[]) { 365 int main(int argc, char* argv[]) {
366 return syncer::SyncClientMain(argc, argv); 366 return syncer::SyncClientMain(argc, argv);
367 } 367 }
OLDNEW
« no previous file with comments | « sync/test/engine/fake_model_worker.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698