Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(148)

Side by Side Diff: remoting/base/rate_counter.h

Issue 1542203002: Switch to standard integer types in remoting/. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@int-remoting-host
Patch Set: Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « remoting/base/dispatch_win.h.pump ('k') | remoting/base/rate_counter.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 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 #ifndef REMOTING_BASE_RATE_COUNTER_H_ 5 #ifndef REMOTING_BASE_RATE_COUNTER_H_
6 #define REMOTING_BASE_RATE_COUNTER_H_ 6 #define REMOTING_BASE_RATE_COUNTER_H_
7 7
8 #include <stdint.h>
9
8 #include <queue> 10 #include <queue>
9 #include <utility> 11 #include <utility>
10 12
11 #include "base/basictypes.h" 13 #include "base/macros.h"
12 #include "base/threading/non_thread_safe.h" 14 #include "base/threading/non_thread_safe.h"
13 #include "base/time/time.h" 15 #include "base/time/time.h"
14 16
15 namespace remoting { 17 namespace remoting {
16 18
17 // Measures average rate per second of a sequence of point rate samples 19 // Measures average rate per second of a sequence of point rate samples
18 // over a specified time window. This can be used to measure bandwidth, frame 20 // over a specified time window. This can be used to measure bandwidth, frame
19 // rates, etc. 21 // rates, etc.
20 class RateCounter : public base::NonThreadSafe { 22 class RateCounter : public base::NonThreadSafe {
21 public: 23 public:
22 // Constructs a rate counter over the specified |time_window|. 24 // Constructs a rate counter over the specified |time_window|.
23 explicit RateCounter(base::TimeDelta time_window); 25 explicit RateCounter(base::TimeDelta time_window);
24 virtual ~RateCounter(); 26 virtual ~RateCounter();
25 27
26 // Records a point event count to include in the rate. 28 // Records a point event count to include in the rate.
27 void Record(int64 value); 29 void Record(int64_t value);
28 30
29 // Returns the rate-per-second of values recorded over the time window. 31 // Returns the rate-per-second of values recorded over the time window.
30 // Note that rates reported before |time_window| has elapsed are not accurate. 32 // Note that rates reported before |time_window| has elapsed are not accurate.
31 double Rate(); 33 double Rate();
32 34
33 // Overrides the current time for testing. 35 // Overrides the current time for testing.
34 void SetCurrentTimeForTest(base::Time current_time); 36 void SetCurrentTimeForTest(base::Time current_time);
35 37
36 private: 38 private:
37 // Type used to store data points with timestamps. 39 // Type used to store data points with timestamps.
38 typedef std::pair<base::Time, int64> DataPoint; 40 typedef std::pair<base::Time, int64_t> DataPoint;
39 41
40 // Removes data points more than |time_window| older than |current_time|. 42 // Removes data points more than |time_window| older than |current_time|.
41 void EvictOldDataPoints(base::Time current_time); 43 void EvictOldDataPoints(base::Time current_time);
42 44
43 // Returns the current time specified for test, if set, or base::Time::Now(). 45 // Returns the current time specified for test, if set, or base::Time::Now().
44 base::Time CurrentTime() const; 46 base::Time CurrentTime() const;
45 47
46 // Time window over which to calculate the rate. 48 // Time window over which to calculate the rate.
47 const base::TimeDelta time_window_; 49 const base::TimeDelta time_window_;
48 50
49 // Queue containing data points in the order in which they were recorded. 51 // Queue containing data points in the order in which they were recorded.
50 std::queue<DataPoint> data_points_; 52 std::queue<DataPoint> data_points_;
51 53
52 // Sum of values in |data_points_|. 54 // Sum of values in |data_points_|.
53 int64 sum_; 55 int64_t sum_;
54 56
55 // If set, used to calculate the running average, in place of Now(). 57 // If set, used to calculate the running average, in place of Now().
56 base::Time current_time_for_test_; 58 base::Time current_time_for_test_;
57 59
58 DISALLOW_COPY_AND_ASSIGN(RateCounter); 60 DISALLOW_COPY_AND_ASSIGN(RateCounter);
59 }; 61 };
60 62
61 } // namespace remoting 63 } // namespace remoting
62 64
63 #endif // REMOTING_BASE_RATE_COUNTER_H_ 65 #endif // REMOTING_BASE_RATE_COUNTER_H_
OLDNEW
« no previous file with comments | « remoting/base/dispatch_win.h.pump ('k') | remoting/base/rate_counter.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698