OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/sync/engine/model_changing_syncer_command.h" | 5 #include "chrome/browser/sync/engine/model_changing_syncer_command.h" |
6 | 6 |
7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
8 #include "base/callback_old.h" | 8 #include "base/callback_old.h" |
9 #include "chrome/browser/sync/engine/model_safe_worker.h" | 9 #include "chrome/browser/sync/engine/model_safe_worker.h" |
10 #include "chrome/browser/sync/sessions/status_controller.h" | 10 #include "chrome/browser/sync/sessions/status_controller.h" |
11 #include "chrome/browser/sync/sessions/sync_session.h" | 11 #include "chrome/browser/sync/sessions/sync_session.h" |
12 #include "chrome/browser/sync/util/unrecoverable_error_info.h" | 12 #include "chrome/browser/sync/util/unrecoverable_error_info.h" |
13 | 13 |
14 namespace browser_sync { | 14 namespace browser_sync { |
15 | 15 |
16 void ModelChangingSyncerCommand::ExecuteImpl(sessions::SyncSession* session) { | 16 void ModelChangingSyncerCommand::ExecuteImpl(sessions::SyncSession* session) { |
17 work_session_ = session; | 17 work_session_ = session; |
18 if (!ModelNeutralExecuteImpl(work_session_)) { | |
19 return; | |
20 } | |
21 | 18 |
22 // Project the list of active types (i.e., types in the routing | 19 // Project the list of active types (i.e., types in the routing |
23 // info) to a list of groups. | 20 // info) to a list of groups. |
24 // | 21 // |
25 // TODO(akalin): Make this overrideable by subclasses (who might be | 22 // TODO(akalin): Make this overrideable by subclasses (who might be |
26 // working on a subset of |active_groups|). (See | 23 // working on a subset of |active_groups|). (See |
27 // http://crbug.com/97832.) | 24 // http://crbug.com/97832.) |
28 std::set<ModelSafeGroup> active_groups; | 25 std::set<ModelSafeGroup> active_groups; |
29 const ModelSafeRoutingInfo& routing_info = session->routing_info(); | 26 const ModelSafeRoutingInfo& routing_info = session->routing_info(); |
30 for (ModelSafeRoutingInfo::const_iterator it = routing_info.begin(); | 27 for (ModelSafeRoutingInfo::const_iterator it = routing_info.begin(); |
(...skipping 21 matching lines...) Expand all Loading... |
52 // We wait until the callback is executed. So it is safe to use | 49 // We wait until the callback is executed. So it is safe to use |
53 // unretained. | 50 // unretained. |
54 base::Unretained(this)); | 51 base::Unretained(this)); |
55 | 52 |
56 // TODO(lipalani): Check the return value for an unrecoverable error. | 53 // TODO(lipalani): Check the return value for an unrecoverable error. |
57 ignore_result(worker->DoWorkAndWaitUntilDone(c)); | 54 ignore_result(worker->DoWorkAndWaitUntilDone(c)); |
58 | 55 |
59 } | 56 } |
60 } | 57 } |
61 | 58 |
62 bool ModelChangingSyncerCommand::ModelNeutralExecuteImpl( | |
63 sessions::SyncSession* session) { | |
64 return true; | |
65 } | |
66 | |
67 } // namespace browser_sync | 59 } // namespace browser_sync |
OLD | NEW |