OLD | NEW |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 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 // StatusController handles all counter and status related number crunching and | 5 // StatusController handles all counter and status related number crunching and |
6 // state tracking on behalf of a SyncSession. | 6 // state tracking on behalf of a SyncSession. |
7 // | 7 // |
8 // This object may be accessed from many different threads. It will be accessed | 8 // This object may be accessed from many different threads. It will be accessed |
9 // most often from the syncer thread. However, when update application is in | 9 // most often from the syncer thread. However, when update application is in |
10 // progress it may also be accessed from the worker threads. This is safe | 10 // progress it may also be accessed from the worker threads. This is safe |
(...skipping 25 matching lines...) Expand all Loading... |
36 ~StatusController(); | 36 ~StatusController(); |
37 | 37 |
38 // ClientToServer messages. | 38 // ClientToServer messages. |
39 const ModelTypeSet commit_request_types() const { | 39 const ModelTypeSet commit_request_types() const { |
40 return model_neutral_.commit_request_types; | 40 return model_neutral_.commit_request_types; |
41 } | 41 } |
42 void set_commit_request_types(ModelTypeSet value) { | 42 void set_commit_request_types(ModelTypeSet value) { |
43 model_neutral_.commit_request_types = value; | 43 model_neutral_.commit_request_types = value; |
44 } | 44 } |
45 | 45 |
46 // Changelog related state. | |
47 int64 num_server_changes_remaining() const { | |
48 return model_neutral_.num_server_changes_remaining; | |
49 } | |
50 | |
51 // Various conflict counters. | 46 // Various conflict counters. |
52 int num_encryption_conflicts() const; | 47 int num_encryption_conflicts() const; |
53 int num_hierarchy_conflicts() const; | 48 int num_hierarchy_conflicts() const; |
54 int num_server_conflicts() const; | 49 int num_server_conflicts() const; |
55 | 50 |
56 // Aggregate sum of all conflicting items over all conflict types. | 51 // Aggregate sum of all conflicting items over all conflict types. |
57 int TotalNumConflictingItems() const; | 52 int TotalNumConflictingItems() const; |
58 | 53 |
59 // Number of successfully applied updates. | 54 // Number of successfully applied updates. |
60 int num_updates_applied() const; | 55 int num_updates_applied() const; |
61 | 56 |
62 int num_server_overwrites() const; | 57 int num_server_overwrites() const; |
63 | 58 |
64 base::Time sync_start_time() const { | 59 base::Time sync_start_time() const { |
65 // The time at which we sent the first GetUpdates command for this sync. | 60 // The time at which we sent the first GetUpdates command for this sync. |
66 return sync_start_time_; | 61 return sync_start_time_; |
67 } | 62 } |
68 | 63 |
69 const ModelNeutralState& model_neutral_state() const { | 64 const ModelNeutralState& model_neutral_state() const { |
70 return model_neutral_; | 65 return model_neutral_; |
71 } | 66 } |
72 | 67 |
73 SyncerError last_get_key_result() const; | 68 SyncerError last_get_key_result() const; |
74 | 69 |
75 // Download counters. | 70 // Download counters. |
76 void set_num_server_changes_remaining(int64 changes_remaining); | |
77 void increment_num_updates_downloaded_by(int value); | 71 void increment_num_updates_downloaded_by(int value); |
78 void increment_num_tombstone_updates_downloaded_by(int value); | 72 void increment_num_tombstone_updates_downloaded_by(int value); |
79 void increment_num_reflected_updates_downloaded_by(int value); | 73 void increment_num_reflected_updates_downloaded_by(int value); |
80 | 74 |
81 // Update application and conflict resolution counters. | 75 // Update application and conflict resolution counters. |
82 void increment_num_updates_applied_by(int value); | 76 void increment_num_updates_applied_by(int value); |
83 void increment_num_encryption_conflicts_by(int value); | 77 void increment_num_encryption_conflicts_by(int value); |
84 void increment_num_hierarchy_conflicts_by(int value); | 78 void increment_num_hierarchy_conflicts_by(int value); |
85 void increment_num_server_conflicts(); | 79 void increment_num_server_conflicts(); |
86 void increment_num_local_overwrites(); | 80 void increment_num_local_overwrites(); |
(...skipping 16 matching lines...) Expand all Loading... |
103 | 97 |
104 base::Time sync_start_time_; | 98 base::Time sync_start_time_; |
105 | 99 |
106 DISALLOW_COPY_AND_ASSIGN(StatusController); | 100 DISALLOW_COPY_AND_ASSIGN(StatusController); |
107 }; | 101 }; |
108 | 102 |
109 } // namespace sessions | 103 } // namespace sessions |
110 } // namespace syncer | 104 } // namespace syncer |
111 | 105 |
112 #endif // SYNC_SESSIONS_STATUS_CONTROLLER_H_ | 106 #endif // SYNC_SESSIONS_STATUS_CONTROLLER_H_ |
OLD | NEW |