| 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/sync_scheduler.h" | 5 #include "chrome/browser/sync/engine/sync_scheduler.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <cstring> | 8 #include <cstring> |
| 9 | 9 |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 988 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 999 copy.is_canary_job = is_canary_job; | 999 copy.is_canary_job = is_canary_job; |
| 1000 DoSyncSessionJob(copy); | 1000 DoSyncSessionJob(copy); |
| 1001 } | 1001 } |
| 1002 } | 1002 } |
| 1003 | 1003 |
| 1004 SyncSession* SyncScheduler::CreateSyncSession(const SyncSourceInfo& source) { | 1004 SyncSession* SyncScheduler::CreateSyncSession(const SyncSourceInfo& source) { |
| 1005 DCHECK_EQ(MessageLoop::current(), sync_loop_); | 1005 DCHECK_EQ(MessageLoop::current(), sync_loop_); |
| 1006 ModelSafeRoutingInfo routes; | 1006 ModelSafeRoutingInfo routes; |
| 1007 std::vector<ModelSafeWorker*> workers; | 1007 std::vector<ModelSafeWorker*> workers; |
| 1008 session_context_->registrar()->GetModelSafeRoutingInfo(&routes); | 1008 session_context_->registrar()->GetModelSafeRoutingInfo(&routes); |
| 1009 VLOG(2) << "Creating sync session with routes " |
| 1010 << ModelSafeRoutingInfoToString(routes); |
| 1009 session_context_->registrar()->GetWorkers(&workers); | 1011 session_context_->registrar()->GetWorkers(&workers); |
| 1010 SyncSourceInfo info(source); | 1012 SyncSourceInfo info(source); |
| 1011 | 1013 |
| 1012 SyncSession* session(new SyncSession(session_context_.get(), this, info, | 1014 SyncSession* session(new SyncSession(session_context_.get(), this, info, |
| 1013 routes, workers)); | 1015 routes, workers)); |
| 1014 | 1016 |
| 1015 return session; | 1017 return session; |
| 1016 } | 1018 } |
| 1017 | 1019 |
| 1018 void SyncScheduler::PollTimerCallback() { | 1020 void SyncScheduler::PollTimerCallback() { |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1105 | 1107 |
| 1106 #undef SVLOG_LOC | 1108 #undef SVLOG_LOC |
| 1107 | 1109 |
| 1108 #undef SVLOG | 1110 #undef SVLOG |
| 1109 | 1111 |
| 1110 #undef SLOG | 1112 #undef SLOG |
| 1111 | 1113 |
| 1112 #undef ENUM_CASE | 1114 #undef ENUM_CASE |
| 1113 | 1115 |
| 1114 } // browser_sync | 1116 } // browser_sync |
| OLD | NEW |