OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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/syncer_thread.h" | 5 #include "chrome/browser/sync/engine/syncer_thread.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <map> | 8 #include <map> |
9 #include <queue> | 9 #include <queue> |
10 | 10 |
(...skipping 538 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
549 silenced_until_ = base::TimeTicks(); | 549 silenced_until_ = base::TimeTicks(); |
550 | 550 |
551 ModelSafeRoutingInfo routes; | 551 ModelSafeRoutingInfo routes; |
552 std::vector<ModelSafeWorker*> workers; | 552 std::vector<ModelSafeWorker*> workers; |
553 session_context_->registrar()->GetModelSafeRoutingInfo(&routes); | 553 session_context_->registrar()->GetModelSafeRoutingInfo(&routes); |
554 session_context_->registrar()->GetWorkers(&workers); | 554 session_context_->registrar()->GetWorkers(&workers); |
555 SyncSourceInfo info(GetAndResetNudgeSource(was_throttled, | 555 SyncSourceInfo info(GetAndResetNudgeSource(was_throttled, |
556 continue_sync_cycle, initial_sync_for_thread, was_nudged)); | 556 continue_sync_cycle, initial_sync_for_thread, was_nudged)); |
557 scoped_ptr<SyncSession> session; | 557 scoped_ptr<SyncSession> session; |
558 | 558 |
559 AutoUnlock unlock(lock_); | 559 base::AutoUnlock unlock(lock_); |
560 do { | 560 do { |
561 session.reset(new SyncSession(session_context_.get(), this, | 561 session.reset(new SyncSession(session_context_.get(), this, |
562 info, routes, workers)); | 562 info, routes, workers)); |
563 VLOG(1) << "Calling SyncShare."; | 563 VLOG(1) << "Calling SyncShare."; |
564 syncer->SyncShare(session.get()); | 564 syncer->SyncShare(session.get()); |
565 } while (session->HasMoreToSync() && silenced_until_.is_null()); | 565 } while (session->HasMoreToSync() && silenced_until_.is_null()); |
566 | 566 |
567 VLOG(1) << "Done calling SyncShare."; | 567 VLOG(1) << "Done calling SyncShare."; |
568 return session.release(); | 568 return session.release(); |
569 } | 569 } |
(...skipping 272 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
842 was_logged = true; | 842 was_logged = true; |
843 VLOG(1) << "UserIdleTime unimplemented on this platform, synchronization " | 843 VLOG(1) << "UserIdleTime unimplemented on this platform, synchronization " |
844 "will not throttle when user idle"; | 844 "will not throttle when user idle"; |
845 } | 845 } |
846 #endif | 846 #endif |
847 | 847 |
848 return 0; | 848 return 0; |
849 } | 849 } |
850 | 850 |
851 } // namespace browser_sync | 851 } // namespace browser_sync |
OLD | NEW |