blob: 27d69fbbddfd25857fdc15908558ee83a7e26d7f [file] [log] [blame]
// Copyright 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include <map>
#include <memory>
#include <string>
#include "base/callback.h"
#include "base/cancelable_callback.h"
#include "base/compiler_specific.h"
#include "base/gtest_prod_util.h"
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "base/sequence_checker.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
#include "components/sync/engine/polling_constants.h"
#include "components/sync/engine_impl/cycle/nudge_tracker.h"
#include "components/sync/engine_impl/cycle/sync_cycle.h"
#include "components/sync/engine_impl/cycle/sync_cycle_context.h"
#include "components/sync/engine_impl/net/server_connection_manager.h"
#include "components/sync/engine_impl/nudge_source.h"
#include "components/sync/engine_impl/sync_scheduler.h"
#include "components/sync/engine_impl/syncer.h"
namespace syncer {
class BackoffDelayProvider;
struct ModelNeutralState;
class SyncSchedulerImpl : public SyncScheduler {
// |name| is a display string to identify the syncer thread. Takes
// ownership of |syncer| and |delay_provider|.
SyncSchedulerImpl(const std::string& name,
BackoffDelayProvider* delay_provider,
SyncCycleContext* context,
Syncer* syncer,
bool ignore_auth_credentials);
// Calls Stop().
~SyncSchedulerImpl() override;
void Start(Mode mode, base::Time last_poll_time) override;
void ScheduleConfiguration(const ConfigurationParams& params) override;
void Stop() override;
void ScheduleLocalNudge(ModelTypeSet types,
const base::Location& nudge_location) override;
void ScheduleLocalRefreshRequest(
ModelTypeSet types,
const base::Location& nudge_location) override;
void ScheduleInvalidationNudge(
ModelType type,
std::unique_ptr<InvalidationInterface> invalidation,
const base::Location& nudge_location) override;
void ScheduleInitialSyncNudge(ModelType model_type) override;
void SetNotificationsEnabled(bool notifications_enabled) override;
void OnCredentialsUpdated() override;
void OnConnectionStatusChange(network::mojom::ConnectionType type) override;
// SyncCycle::Delegate implementation.
void OnThrottled(const base::TimeDelta& throttle_duration) override;
void OnTypesThrottled(ModelTypeSet types,
const base::TimeDelta& throttle_duration) override;
void OnTypesBackedOff(ModelTypeSet types) override;
bool IsAnyThrottleOrBackoff() override;
void OnReceivedShortPollIntervalUpdate(
const base::TimeDelta& new_interval) override;
void OnReceivedLongPollIntervalUpdate(
const base::TimeDelta& new_interval) override;
void OnReceivedCustomNudgeDelays(
const std::map<ModelType, base::TimeDelta>& nudge_delays) override;
void OnReceivedClientInvalidationHintBufferSize(int size) override;
void OnSyncProtocolError(
const SyncProtocolError& sync_protocol_error) override;
void OnReceivedGuRetryDelay(const base::TimeDelta& delay) override;
void OnReceivedMigrationRequest(ModelTypeSet types) override;
bool IsGlobalThrottle() const;
bool IsGlobalBackoff() const;
// Reduces nudge delays for all types to a very short value and prevents their
// further changing by the server. Used to speed up passing of integration
// tests.
void ForceShortNudgeDelayForTest();
enum JobPriority {
// Non-canary jobs respect exponential backoff.
// Canary jobs bypass exponential backoff, so use with extreme caution.
enum PollAdjustType {
// Restart the poll interval.
// Restart the poll interval only if its length has changed.
friend class SyncSchedulerImplTest;
friend class SyncerTest;
FRIEND_TEST_ALL_PREFIXES(SyncSchedulerTest, TransientPollFailure);
FRIEND_TEST_ALL_PREFIXES(SyncSchedulerTest, SuccessfulRetry);
FRIEND_TEST_ALL_PREFIXES(SyncSchedulerTest, FailedRetry);
FRIEND_TEST_ALL_PREFIXES(SyncSchedulerTest, ReceiveNewRetryDelay);
static const char* GetModeString(Mode mode);
// Invoke the syncer to perform a nudge job.
void DoNudgeSyncCycleJob(JobPriority priority);
// Invoke the syncer to perform a configuration job.
void DoConfigurationSyncCycleJob(JobPriority priority);
// Helper function for Do{Nudge,Configuration,Poll}SyncCycleJob.
void HandleSuccess();
// Helper function for Do{Nudge,Configuration,Poll}SyncCycleJob.
void HandleFailure(const ModelNeutralState& model_neutral_state);
// Invoke the Syncer to perform a poll job.
void DoPollSyncCycleJob();
// Helper function to calculate poll interval.
base::TimeDelta GetPollInterval();
// Adjusts the poll timer to account for new poll interval, and possibly
// resets the poll interval, depedning on the flag's value.
void AdjustPolling(PollAdjustType type);
// Helper to restart pending_wakeup_timer_.
// This function need to be called in 3 conditions, backoff/throttling
// happens, unbackoff/unthrottling happens and after |PerformDelayedNudge|
// runs.
// This function is for scheduling unbackoff/unthrottling jobs, and the
// poriority is, global unbackoff/unthrottling job first, if there is no
// global backoff/throttling, then try to schedule types
// unbackoff/unthrottling job.
void RestartWaiting();
// Determines if we're allowed to contact the server right now.
bool CanRunJobNow(JobPriority priority);
// Determines if we're allowed to contact the server right now.
bool CanRunNudgeJobNow(JobPriority priority);
// If the scheduler's current state supports it, this will create a job based
// on the passed in parameters and coalesce it with any other pending jobs,
// then post a delayed task to run it. It may also choose to drop the job or
// save it for later, depending on the scheduler's current state.
void ScheduleNudgeImpl(const base::TimeDelta& delay,
const base::Location& nudge_location);
// Helper to signal listeners about changed retry time.
void NotifyRetryTime(base::Time retry_time);
// Helper to signal listeners about changed throttled or backed off types.
void NotifyBlockedTypesChanged();
// Looks for pending work and, if it finds any, run this work at "canary"
// priority.
void TryCanaryJob();
// At the moment TrySyncCycleJob just posts call to TrySyncCycleJobImpl on
// current thread. In the future it will request access token here.
void TrySyncCycleJob();
void TrySyncCycleJobImpl();
// Transitions out of the THROTTLED WaitInterval then calls TryCanaryJob().
// This function is for global throttling.
void Unthrottle();
// Called when a per-type throttling or backing off interval expires.
void OnTypesUnblocked();
// Runs a normal nudge job when the scheduled timer expires.
void PerformDelayedNudge();
// Attempts to exit EXPONENTIAL_BACKOFF by calling TryCanaryJob().
// This function is for global backoff.
void ExponentialBackoffRetry();
// Called when the root cause of the current connection error is fixed.
void OnServerConnectionErrorFixed();
// Creates a cycle for a poll and performs the sync.
void PollTimerCallback();
// Creates a cycle for a retry and performs the sync.
void RetryTimerCallback();
// Returns the set of types that are enabled and not currently throttled and
// backed off.
ModelTypeSet GetEnabledAndUnblockedTypes();
// Called as we are started to broadcast an initial cycle snapshot
// containing data like initial_sync_ended. Important when the client starts
// up and does not need to perform an initial sync.
void SendInitialSnapshot();
bool IsEarlierThanCurrentPendingJob(const base::TimeDelta& delay);
// Computes the last poll time the system should assume on start-up.
static base::Time ComputeLastPollOnStart(base::Time last_poll,
base::TimeDelta poll_interval,
base::Time now);
// Used for logging.
const std::string name_;
// Set in Start(), unset in Stop().
bool started_;
// Modifiable versions of kDefaultLongPollIntervalSeconds which can be
// updated by the server.
base::TimeDelta syncer_short_poll_interval_seconds_;
base::TimeDelta syncer_long_poll_interval_seconds_;
// Timer for polling. Restarted on each successful poll, and when entering
// normal sync mode or exiting an error state. Not active in configuration
// mode.
base::OneShotTimer poll_timer_;
// The mode of operation.
Mode mode_;
// Current wait state. Null if we're not in backoff and not throttled.
std::unique_ptr<WaitInterval> wait_interval_;
std::unique_ptr<BackoffDelayProvider> delay_provider_;
// TODO(gangwu): too many timers in this class, try to
// reduce them.
// The event that will wake us up.
// When the whole client got throttling or backoff, we will delay this timer
// as well.
base::OneShotTimer pending_wakeup_timer_;
// Storage for variables related to an in-progress configure request. Note
// that (mode_ != CONFIGURATION_MODE) \implies !pending_configure_params_.
std::unique_ptr<ConfigurationParams> pending_configure_params_;
// Keeps track of work that the syncer needs to handle.
NudgeTracker nudge_tracker_;
// Invoked to run through the sync cycle.
std::unique_ptr<Syncer> syncer_;
SyncCycleContext* cycle_context_;
// TryJob might get called for multiple reasons. It should only call
// DoPollSyncCycleJob after some time since the last attempt.
// last_poll_reset_ keeps track of when was last attempt.
base::TimeTicks last_poll_reset_;
// next_sync_cycle_job_priority_ defines which priority will be used next
// time TrySyncCycleJobImpl is called. CANARY_PRIORITY allows syncer to run
// even if scheduler is in exponential backoff. This is needed for events that
// have chance of resolving previous error (e.g. network connection change
// after NETWORK_UNAVAILABLE error).
// It is reset back to NORMAL_PRIORITY on every call to TrySyncCycleJobImpl.
JobPriority next_sync_cycle_job_priority_;
// One-shot timer for scheduling GU retry according to delay set by server.
base::OneShotTimer retry_timer_;
// Dictates if the scheduler should wait for authentication to happen or not.
bool ignore_auth_credentials_;
// Used to prevent changing nudge delays by the server in integration tests.
bool force_short_nudge_delay_for_test_ = false;
base::WeakPtrFactory<SyncSchedulerImpl> weak_ptr_factory_;
} // namespace syncer