Lines Matching refs:SyncerThread
24 SyncerThread::DelayProvider::DelayProvider() {}
25 SyncerThread::DelayProvider::~DelayProvider() {}
27 SyncerThread::WaitInterval::WaitInterval() {}
28 SyncerThread::WaitInterval::~WaitInterval() {}
30 SyncerThread::SyncSessionJob::SyncSessionJob() {}
31 SyncerThread::SyncSessionJob::~SyncSessionJob() {}
33 SyncerThread::SyncSessionJob::SyncSessionJob(SyncSessionJobPurpose purpose,
43 TimeDelta SyncerThread::DelayProvider::GetDelay(
45 return SyncerThread::GetRecommendedDelay(last_delay);
65 SyncerThread::WaitInterval::WaitInterval(Mode mode, TimeDelta length)
68 SyncerThread::SyncerThread(sessions::SyncSessionContext* context,
82 SyncerThread::~SyncerThread() {
86 void SyncerThread::CheckServerConnectionManagerStatus(
89 VLOG(1) << "SyncerThread(" << this << ")" << " Server connection changed."
91 // Note, be careful when adding cases here because if the SyncerThread
100 VLOG(1) << "SyncerThread(" << this << ")" << " Server connection changed."
104 VLOG(1) << "SyncerThread(" << this << ")" << " Server connection changed."
110 void SyncerThread::Start(Mode mode, ModeChangeCallback* callback) {
111 VLOG(1) << "SyncerThread(" << this << ")" << " Start called from thread "
114 VLOG(1) << "SyncerThread(" << this << ")" << " Starting thread with mode "
117 NOTREACHED() << "Unable to start SyncerThread.";
122 this, &SyncerThread::SendInitialSnapshot));
125 VLOG(1) << "SyncerThread(" << this << ")" << " Entering start with mode = "
129 this, &SyncerThread::StartImpl, mode, callback));
132 void SyncerThread::SendInitialSnapshot() {
143 void SyncerThread::WatchConnectionManager() {
149 void SyncerThread::StartImpl(Mode mode, ModeChangeCallback* callback) {
150 VLOG(1) << "SyncerThread(" << this << ")" << " Doing StartImpl with mode "
169 SyncerThread::JobProcessDecision SyncerThread::DecideWhileInWaitInterval(
175 VLOG(1) << "SyncerThread(" << this << ")" << " Wait interval mode : "
201 SyncerThread::JobProcessDecision SyncerThread::DecideOnJob(
224 VLOG(1) << "SyncerThread(" << this << ")"
232 VLOG(1) << "SyncerThread(" << this << ")"
237 void SyncerThread::InitOrCoalescePendingJob(const SyncSessionJob& job) {
240 VLOG(1) << "SyncerThread(" << this << ")"
253 VLOG(1) << "SyncerThread(" << this << ")" << " Coalescing a pending nudge";
261 bool SyncerThread::ShouldRunJob(const SyncSessionJob& job) {
263 VLOG(1) << "SyncerThread(" << this << ")" << " Should run job, decision: "
275 void SyncerThread::SaveJob(const SyncSessionJob& job) {
278 VLOG(1) << "SyncerThread(" << this << ")" << " Saving a nudge job";
281 VLOG(1) << "SyncerThread(" << this << ")" << " Saving a configuration job";
303 void SyncerThread::ScheduleClearUserData() {
309 this, &SyncerThread::ScheduleClearUserDataImpl));
312 void SyncerThread::ScheduleNudge(const TimeDelta& delay,
320 VLOG(1) << "SyncerThread(" << this << ")" << " Nudge scheduled";
325 this, &SyncerThread::ScheduleNudgeImpl, delay,
330 void SyncerThread::ScheduleNudgeWithPayloads(const TimeDelta& delay,
338 VLOG(1) << "SyncerThread(" << this << ")" << " Nudge scheduled with payloads";
341 this, &SyncerThread::ScheduleNudgeImpl, delay,
346 void SyncerThread::ScheduleClearUserDataImpl() {
355 void SyncerThread::ScheduleNudgeImpl(const TimeDelta& delay,
361 VLOG(1) << "SyncerThread(" << this << ")" << " Running Schedule nudge impl";
378 VLOG(1) << "SyncerThread(" << this << ")" << " Dropping the nudge because"
383 VLOG(1) << "SyncerThread(" << this << ")" << " Coalescing pending nudge";
387 VLOG(1) << "SyncerThread(" << this << ")" << " Dropping a nudge because"
391 VLOG(1) << "SyncerThread(" << this << ")"
450 void SyncerThread::ScheduleConfig(const ModelTypeBitSet& types) {
456 VLOG(1) << "SyncerThread(" << this << ")" << " Scheduling a config";
463 this, &SyncerThread::ScheduleConfigImpl, routes, workers,
467 void SyncerThread::ScheduleConfigImpl(const ModelSafeRoutingInfo& routing_info,
472 VLOG(1) << "SyncerThread(" << this << ")" << " ScheduleConfigImpl...";
483 void SyncerThread::ScheduleSyncSessionJob(const base::TimeDelta& delay,
492 VLOG(1) << "SyncerThread(" << this << ")" << " Resetting pending_nudge in"
497 VLOG(1) << "SyncerThread(" << this << ")"
501 &SyncerThread::DoSyncSessionJob, job),
505 void SyncerThread::SetSyncerStepsForPurpose(
526 void SyncerThread::DoSyncSessionJob(const SyncSessionJob& job) {
539 VLOG(1) << "SyncerThread(" << this << ")" << " DoSyncSessionJob. job purpose "
548 VLOG(1) << "SyncerThread(" << this << ")"
549 << " SyncerThread: Calling SyncShare.";
556 VLOG(1) << "SyncerThread(" << this << ")"
557 << " SyncerThread: Done SyncShare looping.";
561 void SyncerThread::UpdateCarryoverSessionState(const SyncSessionJob& old_job) {
580 void SyncerThread::FinishSyncSessionJob(const SyncSessionJob& job) {
596 VLOG(1) << "SyncerThread(" << this << ")"
602 VLOG(1) << "SyncerThread(" << this << ")"
607 void SyncerThread::ScheduleNextSync(const SyncSessionJob& old_job) {
619 VLOG(1) << "SyncerThread(" << this << ")" << " syncer has work to do: "
631 VLOG(1) << "SyncerThread(" << this << ")"
638 VLOG(1) << "SyncerThread(" << this << ")"
643 VLOG(1) << "SyncerThread(" << this << ")"
651 VLOG(1) << "SyncerThread(" << this << ")"
668 void SyncerThread::AdjustPolling(const SyncSessionJob* old_job) {
686 poll_timer_.Start(poll, this, &SyncerThread::PollTimerCallback);
689 void SyncerThread::HandleConsecutiveContinuationError(
702 VLOG(1) << "SyncerThread(" << this << ")"
705 VLOG(1) << "SyncerThread(" << this << ")"
724 wait_interval_->timer.Start(length, this, &SyncerThread::DoCanaryJob);
728 TimeDelta SyncerThread::GetRecommendedDelay(const TimeDelta& last_delay) {
751 void SyncerThread::Stop() {
752 VLOG(1) << "SyncerThread(" << this << ")" << " stop called";
758 void SyncerThread::DoCanaryJob() {
759 VLOG(1) << "SyncerThread(" << this << ")" << " Do canary job";
763 void SyncerThread::DoPendingJobIfPossible(bool is_canary_job) {
767 VLOG(1) << "SyncerThread(" << this << ")" << " Found pending configure job";
770 VLOG(1) << "SyncerThread(" << this << ")" << " Found pending nudge job";
787 VLOG(1) << "SyncerThread(" << this << ")" << " Executing pending job";
794 SyncSession* SyncerThread::CreateSyncSession(const SyncSourceInfo& source) {
807 void SyncerThread::PollTimerCallback() {
818 void SyncerThread::Unthrottle() {
820 VLOG(1) << "SyncerThread(" << this << ")" << " Unthrottled..";
825 void SyncerThread::Notify(SyncEngineEvent::EventCause cause) {
830 bool SyncerThread::IsBackingOff() const {
835 void SyncerThread::OnSilencedUntil(const base::TimeTicks& silenced_until) {
839 &SyncerThread::Unthrottle);
842 bool SyncerThread::IsSyncingCurrentlySilenced() {
847 void SyncerThread::OnReceivedShortPollIntervalUpdate(
853 void SyncerThread::OnReceivedLongPollIntervalUpdate(
859 void SyncerThread::OnShouldStopSyncingPermanently() {
860 VLOG(1) << "SyncerThread(" << this << ")"
866 void SyncerThread::OnServerConnectionEvent(
869 &SyncerThread::CheckServerConnectionManagerStatus,
873 void SyncerThread::set_notifications_enabled(bool notifications_enabled) {
