OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 #include "chromecast/base/metrics/cast_metrics_helper.h" | 5 #include "chromecast/base/metrics/cast_metrics_helper.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/location.h" | 9 #include "base/location.h" |
10 #include "base/message_loop/message_loop_proxy.h" | |
11 #include "base/metrics/histogram.h" | 10 #include "base/metrics/histogram.h" |
12 #include "base/metrics/user_metrics.h" | 11 #include "base/metrics/user_metrics.h" |
| 12 #include "base/single_thread_task_runner.h" |
13 #include "base/strings/string_split.h" | 13 #include "base/strings/string_split.h" |
14 #include "base/strings/string_util.h" | 14 #include "base/strings/string_util.h" |
15 #include "chromecast/base/metrics/cast_histograms.h" | 15 #include "chromecast/base/metrics/cast_histograms.h" |
16 #include "chromecast/base/metrics/grouped_histogram.h" | 16 #include "chromecast/base/metrics/grouped_histogram.h" |
17 | 17 |
18 namespace chromecast { | 18 namespace chromecast { |
19 namespace metrics { | 19 namespace metrics { |
20 | 20 |
21 // A useful macro to make sure current member function runs on the valid thread. | 21 // A useful macro to make sure current member function runs on the valid thread. |
22 #define MAKE_SURE_THREAD(callback, ...) \ | 22 #define MAKE_SURE_THREAD(callback, ...) \ |
23 if (!message_loop_proxy_->BelongsToCurrentThread()) { \ | 23 if (!task_runner_->BelongsToCurrentThread()) { \ |
24 message_loop_proxy_->PostTask(FROM_HERE, base::Bind( \ | 24 task_runner_->PostTask(FROM_HERE, \ |
25 &CastMetricsHelper::callback, \ | 25 base::Bind(&CastMetricsHelper::callback, \ |
26 base::Unretained(this), ##__VA_ARGS__)); \ | 26 base::Unretained(this), ##__VA_ARGS__)); \ |
27 return; \ | 27 return; \ |
28 } | 28 } |
29 | 29 |
30 namespace { | 30 namespace { |
31 | 31 |
32 CastMetricsHelper* g_instance = NULL; | 32 CastMetricsHelper* g_instance = NULL; |
33 | 33 |
34 // Displayed frames are logged in frames per second (but sampling can be over | 34 // Displayed frames are logged in frames per second (but sampling can be over |
35 // a longer period of time, e.g. 5 seconds). | 35 // a longer period of time, e.g. 5 seconds). |
36 const int kDisplayedFramesPerSecondPeriod = 1000000; | 36 const int kDisplayedFramesPerSecondPeriod = 1000000; |
37 | 37 |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 return JoinString(parts, kMetricsNameAppInfoDelimiter); | 86 return JoinString(parts, kMetricsNameAppInfoDelimiter); |
87 } | 87 } |
88 | 88 |
89 // static | 89 // static |
90 CastMetricsHelper* CastMetricsHelper::GetInstance() { | 90 CastMetricsHelper* CastMetricsHelper::GetInstance() { |
91 DCHECK(g_instance); | 91 DCHECK(g_instance); |
92 return g_instance; | 92 return g_instance; |
93 } | 93 } |
94 | 94 |
95 CastMetricsHelper::CastMetricsHelper( | 95 CastMetricsHelper::CastMetricsHelper( |
96 scoped_refptr<base::MessageLoopProxy> message_loop_proxy) | 96 scoped_refptr<base::SingleThreadTaskRunner> task_runner) |
97 : message_loop_proxy_(message_loop_proxy), | 97 : task_runner_(task_runner), |
98 metrics_sink_(NULL), | 98 metrics_sink_(NULL), |
99 record_action_callback_(base::Bind(&base::RecordComputedAction)) { | 99 record_action_callback_(base::Bind(&base::RecordComputedAction)) { |
100 DCHECK(message_loop_proxy_.get()); | 100 DCHECK(task_runner_.get()); |
101 DCHECK(!g_instance); | 101 DCHECK(!g_instance); |
102 g_instance = this; | 102 g_instance = this; |
103 } | 103 } |
104 | 104 |
105 CastMetricsHelper::CastMetricsHelper() | 105 CastMetricsHelper::CastMetricsHelper() |
106 : metrics_sink_(NULL) { | 106 : metrics_sink_(NULL) { |
107 DCHECK(!g_instance); | 107 DCHECK(!g_instance); |
108 g_instance = this; | 108 g_instance = this; |
109 } | 109 } |
110 | 110 |
(...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
244 value, 50); | 244 value, 50); |
245 } | 245 } |
246 } | 246 } |
247 | 247 |
248 previous_video_stat_sample_time_ = sample_time; | 248 previous_video_stat_sample_time_ = sample_time; |
249 } | 249 } |
250 | 250 |
251 std::string CastMetricsHelper::GetMetricsNameWithAppName( | 251 std::string CastMetricsHelper::GetMetricsNameWithAppName( |
252 const std::string& prefix, | 252 const std::string& prefix, |
253 const std::string& suffix) const { | 253 const std::string& suffix) const { |
254 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); | 254 DCHECK(task_runner_->BelongsToCurrentThread()); |
255 std::string metrics_name(prefix); | 255 std::string metrics_name(prefix); |
256 if (!app_id_.empty()) { | 256 if (!app_id_.empty()) { |
257 if (!metrics_name.empty()) | 257 if (!metrics_name.empty()) |
258 metrics_name.push_back('.'); | 258 metrics_name.push_back('.'); |
259 metrics_name.append(app_id_); | 259 metrics_name.append(app_id_); |
260 } | 260 } |
261 if (!suffix.empty()) { | 261 if (!suffix.empty()) { |
262 if (!metrics_name.empty()) | 262 if (!metrics_name.empty()) |
263 metrics_name.push_back('.'); | 263 metrics_name.push_back('.'); |
264 metrics_name.append(suffix); | 264 metrics_name.append(suffix); |
265 } | 265 } |
266 return metrics_name; | 266 return metrics_name; |
267 } | 267 } |
268 | 268 |
269 void CastMetricsHelper::SetMetricsSink(MetricsSink* delegate) { | 269 void CastMetricsHelper::SetMetricsSink(MetricsSink* delegate) { |
270 MAKE_SURE_THREAD(SetMetricsSink, delegate); | 270 MAKE_SURE_THREAD(SetMetricsSink, delegate); |
271 metrics_sink_ = delegate; | 271 metrics_sink_ = delegate; |
272 } | 272 } |
273 | 273 |
274 void CastMetricsHelper::SetRecordActionCallback( | 274 void CastMetricsHelper::SetRecordActionCallback( |
275 const RecordActionCallback& callback) { | 275 const RecordActionCallback& callback) { |
276 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); | 276 DCHECK(task_runner_->BelongsToCurrentThread()); |
277 record_action_callback_ = callback; | 277 record_action_callback_ = callback; |
278 } | 278 } |
279 | 279 |
280 void CastMetricsHelper::RecordSimpleAction(const std::string& action) { | 280 void CastMetricsHelper::RecordSimpleAction(const std::string& action) { |
281 MAKE_SURE_THREAD(RecordSimpleAction, action); | 281 MAKE_SURE_THREAD(RecordSimpleAction, action); |
282 | 282 |
283 if (metrics_sink_) { | 283 if (metrics_sink_) { |
284 metrics_sink_->OnAction(action); | 284 metrics_sink_->OnAction(action); |
285 } else { | 285 } else { |
286 record_action_callback_.Run(action); | 286 record_action_callback_.Run(action); |
(...skipping 30 matching lines...) Expand all Loading... |
317 const base::TimeDelta& value) { | 317 const base::TimeDelta& value) { |
318 // Follow UMA_HISTOGRAM_MEDIUM_TIMES definition. | 318 // Follow UMA_HISTOGRAM_MEDIUM_TIMES definition. |
319 LogTimeHistogramEvent(name, value, | 319 LogTimeHistogramEvent(name, value, |
320 base::TimeDelta::FromMilliseconds(10), | 320 base::TimeDelta::FromMilliseconds(10), |
321 base::TimeDelta::FromMinutes(3), | 321 base::TimeDelta::FromMinutes(3), |
322 50); | 322 50); |
323 } | 323 } |
324 | 324 |
325 } // namespace metrics | 325 } // namespace metrics |
326 } // namespace chromecast | 326 } // namespace chromecast |
OLD | NEW |