1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
// Copyright 2013 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.
//
// A class to track the outstanding work required to bring the client back into
// sync with the server.
#ifndef SYNC_SESSIONS_NUDGE_TRACKER_H_
#define SYNC_SESSIONS_NUDGE_TRACKER_H_
#include <list>
#include <map>
#include "base/compiler_specific.h"
#include "sync/base/sync_export.h"
#include "sync/internal_api/public/base/model_type.h"
#include "sync/protocol/sync.pb.h"
#include "sync/sessions/data_type_tracker.h"
namespace syncer {
class ObjectIdInvalidationMap;
namespace sessions {
class SYNC_EXPORT_PRIVATE NudgeTracker {
public:
static size_t kDefaultMaxPayloadsPerType;
NudgeTracker();
~NudgeTracker();
// Returns true if there is a good reason for performing a sync cycle.
// This does not take into account whether or not this is a good *time* to
// perform a sync cycle; that's the scheduler's job.
bool IsSyncRequired() const;
// Returns true if there is a good reason for performing a get updates
// request as part of the next sync cycle.
bool IsGetUpdatesRequired() const;
// Tells this class that all required update fetching and committing has
// completed successfully.
void RecordSuccessfulSyncCycle();
// Takes note of a local change.
void RecordLocalChange(ModelTypeSet types);
// Takes note of a locally issued request to refresh a data type.
void RecordLocalRefreshRequest(ModelTypeSet types);
// Takes note of the receipt of an invalidation notice from the server.
void RecordRemoteInvalidation(
const ObjectIdInvalidationMap& invalidation_map);
// These functions should be called to keep this class informed of the status
// of the connection to the invalidations server.
void OnInvalidationsEnabled();
void OnInvalidationsDisabled();
// Marks |types| as being throttled from |now| until |now| + |length|.
void SetTypesThrottledUntil(ModelTypeSet types,
base::TimeDelta length,
base::TimeTicks now);
// Removes any throttling that have expired by time |now|.
void UpdateTypeThrottlingState(base::TimeTicks now);
// Returns the time of the next type unthrottling, relative to
// the input |now| value.
base::TimeDelta GetTimeUntilNextUnthrottle(base::TimeTicks now) const;
// Returns true if any type is currenlty throttled.
bool IsAnyTypeThrottled() const;
// Returns true if |type| is currently throttled.
bool IsTypeThrottled(ModelType type) const;
// Returns the set of currently throttled types.
ModelTypeSet GetThrottledTypes() const;
// Returns the 'source' of the GetUpdate request.
//
// This flag is deprecated, but still used by the server. There can be more
// than one reason to perform a particular sync cycle. The GetUpdatesTrigger
// message will contain more reliable information about the reasons for
// performing a sync.
//
// See the implementation for important information about the coalesce logic.
sync_pb::GetUpdatesCallerInfo::GetUpdatesSource updates_source() const;
// Fills a GetUpdatesTrigger message for the next GetUpdates request. This is
// used by the DownloadUpdatesCommand to dump lots of useful per-type state
// information into the GetUpdate request before sending it off to the server.
void FillProtoMessage(
ModelType type,
sync_pb::GetUpdateTriggers* msg) const;
// Fills a ProgressMarker with single legacy notification hint expected by the
// sync server. Newer servers will rely on the data set by FillProtoMessage()
// instead of this.
void SetLegacyNotificationHint(
ModelType type,
sync_pb::DataTypeProgressMarker* progress) const;
// Adjusts the number of hints that can be stored locally.
void SetHintBufferSize(size_t size);
private:
typedef std::map<ModelType, DataTypeTracker> TypeTrackerMap;
TypeTrackerMap type_trackers_;
// Merged updates source. This should be obsolete, but the server still
// relies on it for some heuristics.
sync_pb::GetUpdatesCallerInfo::GetUpdatesSource updates_source_;
// Tracks whether or not invalidations are currently enabled.
bool invalidations_enabled_;
// This flag is set if suspect that some technical malfunction or known bug
// may have left us with some unserviced invalidations.
//
// Keeps track of whether or not we're fully in sync with the invalidation
// server. This can be false even if invalidations are enabled and working
// correctly. For example, until we get ack-tracking working properly, we
// won't persist invalidations between restarts, so we may be out of sync when
// we restart. The only way to get back into sync is to have invalidations
// enabled, then complete a sync cycle to make sure we're fully up to date.
bool invalidations_out_of_sync_;
size_t num_payloads_per_type_;
DISALLOW_COPY_AND_ASSIGN(NudgeTracker);
};
} // namespace sessions
} // namespace syncer
#endif // SYNC_SESSIONS_NUDGE_TRACKER_H_
|
