OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // A class to track the per-type scheduling data. | 5 // A class to track the per-type scheduling data. |
6 #ifndef SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ | 6 #ifndef SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ |
7 #define SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ | 7 #define SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ |
8 | 8 |
9 #include <deque> | 9 #include <list> |
10 #include <string> | 10 #include <string> |
11 | 11 |
12 #include "base/basictypes.h" | 12 #include "base/basictypes.h" |
| 13 #include "base/memory/scoped_ptr.h" |
| 14 #include "base/memory/scoped_vector.h" |
13 #include "base/time/time.h" | 15 #include "base/time/time.h" |
14 #include "sync/notifier/dropped_invalidation_tracker.h" | 16 #include "sync/internal_api/public/base/invalidation_interface.h" |
15 #include "sync/notifier/single_object_invalidation_set.h" | 17 #include "sync/internal_api/public/base/model_type.h" |
16 #include "sync/protocol/sync.pb.h" | 18 #include "sync/protocol/sync.pb.h" |
17 | 19 |
18 namespace syncer { | 20 namespace syncer { |
19 | 21 |
20 class Invalidation; | 22 class InvalidationInterface; |
21 class SingleObjectInvalidationSet; | |
22 | 23 |
23 namespace sessions { | 24 namespace sessions { |
24 | 25 |
25 typedef std::deque<std::string> PayloadList; | |
26 | |
27 class DataTypeTracker { | 26 class DataTypeTracker { |
28 public: | 27 public: |
29 explicit DataTypeTracker(const invalidation::ObjectId& object_id); | 28 explicit DataTypeTracker(); |
30 ~DataTypeTracker(); | 29 ~DataTypeTracker(); |
31 | 30 |
32 // For STL compatibility, we do not forbid the creation of a default copy | 31 // For STL compatibility, we do not forbid the creation of a default copy |
33 // constructor and assignment operator. | 32 // constructor and assignment operator. |
34 | 33 |
35 // Tracks that a local change has been made to this type. | 34 // Tracks that a local change has been made to this type. |
36 void RecordLocalChange(); | 35 void RecordLocalChange(); |
37 | 36 |
38 // Tracks that a local refresh request has been made for this type. | 37 // Tracks that a local refresh request has been made for this type. |
39 void RecordLocalRefreshRequest(); | 38 void RecordLocalRefreshRequest(); |
40 | 39 |
41 // Tracks that we received invalidation notifications for this type. | 40 // Tracks that we received invalidation notifications for this type. |
42 void RecordRemoteInvalidations( | 41 void RecordRemoteInvalidation(scoped_ptr<InvalidationInterface> incoming); |
43 const SingleObjectInvalidationSet& invalidations); | |
44 | 42 |
45 // Records that a sync cycle has been performed successfully. | 43 // Records that a sync cycle has been performed successfully. |
46 // Generally, this means that all local changes have been committed and all | 44 // Generally, this means that all local changes have been committed and all |
47 // remote changes have been downloaded, so we can clear any flags related to | 45 // remote changes have been downloaded, so we can clear any flags related to |
48 // pending work. | 46 // pending work. |
49 void RecordSuccessfulSyncCycle(); | 47 void RecordSuccessfulSyncCycle(); |
50 | 48 |
51 // Updates the size of the invalidations payload buffer. | 49 // Updates the size of the invalidations payload buffer. |
52 void UpdatePayloadBufferSize(size_t new_size); | 50 void UpdatePayloadBufferSize(size_t new_size); |
53 | 51 |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
98 // successful sync cycle. | 96 // successful sync cycle. |
99 int local_nudge_count_; | 97 int local_nudge_count_; |
100 | 98 |
101 // Number of local refresh requests received for this type since the last | 99 // Number of local refresh requests received for this type since the last |
102 // successful sync cycle. | 100 // successful sync cycle. |
103 int local_refresh_request_count_; | 101 int local_refresh_request_count_; |
104 | 102 |
105 // The list of invalidations received since the last successful sync cycle. | 103 // The list of invalidations received since the last successful sync cycle. |
106 // This list may be incomplete. See also: | 104 // This list may be incomplete. See also: |
107 // drop_tracker_.IsRecoveringFromDropEvent() and server_payload_overflow_. | 105 // drop_tracker_.IsRecoveringFromDropEvent() and server_payload_overflow_. |
108 SingleObjectInvalidationSet pending_invalidations_; | 106 std::list<scoped_ptr<InvalidationInterface> > pending_invalidations_; |
109 | 107 |
110 size_t payload_buffer_size_; | 108 size_t payload_buffer_size_; |
111 | 109 |
112 // If !unthrottle_time_.is_null(), this type is throttled and may not download | 110 // If !unthrottle_time_.is_null(), this type is throttled and may not download |
113 // or commit data until the specified time. | 111 // or commit data until the specified time. |
114 base::TimeTicks unthrottle_time_; | 112 base::TimeTicks unthrottle_time_; |
115 | 113 |
116 // A helper to keep track invalidations we dropped due to overflow. | 114 // A helper to keep track invalidations we dropped due to overflow. |
117 DroppedInvalidationTracker drop_tracker_; | 115 scoped_ptr<InvalidationInterface> last_dropped_invalidation_; |
| 116 |
| 117 DISALLOW_COPY_AND_ASSIGN(DataTypeTracker); |
118 }; | 118 }; |
119 | 119 |
| 120 } // namespace sessions |
120 } // namespace syncer | 121 } // namespace syncer |
121 } // namespace sessions | |
122 | 122 |
123 #endif // SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ | 123 #endif // SYNC_SESSIONS_DATA_TYPE_TRACKER_H_ |
OLD | NEW |