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 "sync/engine/sync_scheduler_impl.h" | 5 #include "sync/engine/sync_scheduler_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <cstring> | 8 #include <cstring> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 889 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
900 void SyncSchedulerImpl::HandleContinuationError( | 900 void SyncSchedulerImpl::HandleContinuationError( |
901 const SyncSessionJob& old_job) { | 901 const SyncSessionJob& old_job) { |
902 DCHECK_EQ(MessageLoop::current(), sync_loop_); | 902 DCHECK_EQ(MessageLoop::current(), sync_loop_); |
903 if (DCHECK_IS_ON()) { | 903 if (DCHECK_IS_ON()) { |
904 if (IsBackingOff()) { | 904 if (IsBackingOff()) { |
905 DCHECK(wait_interval_->timer.IsRunning() || old_job.is_canary_job); | 905 DCHECK(wait_interval_->timer.IsRunning() || old_job.is_canary_job); |
906 } | 906 } |
907 } | 907 } |
908 | 908 |
909 TimeDelta length = delay_provider_->GetDelay( | 909 TimeDelta length = delay_provider_->GetDelay( |
910 IsBackingOff() ? wait_interval_->length : TimeDelta::FromSeconds(1)); | 910 IsBackingOff() ? wait_interval_->length : TimeDelta::FromMinutes(5)); |
rlarocque
2012/08/08 01:58:23
While you're changing this, maybe it should be mov
tim (not reviewing)
2012/08/08 05:57:04
I actually want to do that, but I want to keep thi
| |
911 | 911 |
912 SDVLOG(2) << "In handle continuation error with " | 912 SDVLOG(2) << "In handle continuation error with " |
913 << SyncSessionJob::GetPurposeString(old_job.purpose) | 913 << SyncSessionJob::GetPurposeString(old_job.purpose) |
914 << " job. The time delta(ms) is " | 914 << " job. The time delta(ms) is " |
915 << length.InMilliseconds(); | 915 << length.InMilliseconds(); |
916 | 916 |
917 // This will reset the had_nudge variable as well. | 917 // This will reset the had_nudge variable as well. |
918 wait_interval_.reset(new WaitInterval(WaitInterval::EXPONENTIAL_BACKOFF, | 918 wait_interval_.reset(new WaitInterval(WaitInterval::EXPONENTIAL_BACKOFF, |
919 length)); | 919 length)); |
920 if (old_job.purpose == SyncSessionJob::CONFIGURATION) { | 920 if (old_job.purpose == SyncSessionJob::CONFIGURATION) { |
(...skipping 226 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1147 | 1147 |
1148 #undef SDVLOG_LOC | 1148 #undef SDVLOG_LOC |
1149 | 1149 |
1150 #undef SDVLOG | 1150 #undef SDVLOG |
1151 | 1151 |
1152 #undef SLOG | 1152 #undef SLOG |
1153 | 1153 |
1154 #undef ENUM_CASE | 1154 #undef ENUM_CASE |
1155 | 1155 |
1156 } // namespace syncer | 1156 } // namespace syncer |
OLD | NEW |