Avi Drissman | e4622aa | 2022-09-08 20:36:06 | [diff] [blame] | 1 | // Copyright 2014 The Chromium Authors |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
| 5 | #include "base/metrics/user_metrics.h" |
| 6 | |
avi | 9b6f4293 | 2015-12-26 22:15:14 | [diff] [blame] | 7 | #include <stddef.h> |
| 8 | |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 9 | #include <vector> |
| 10 | |
Avi Drissman | 63e1f99 | 2023-01-13 18:54:43 | [diff] [blame^] | 11 | #include "base/functional/bind.h" |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 12 | #include "base/lazy_instance.h" |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 13 | #include "base/location.h" |
Peter Kasting | fea6bb7 | 2022-09-29 16:41:24 | [diff] [blame] | 14 | #include "base/ranges/algorithm.h" |
[email protected] | abca098 | 2014-04-10 01:12:36 | [diff] [blame] | 15 | #include "base/threading/thread_checker.h" |
bttk | c8a31b70 | 2020-02-25 02:55:17 | [diff] [blame] | 16 | #include "base/time/time.h" |
Eric Seckler | f6c544f | 2020-06-02 10:49:21 | [diff] [blame] | 17 | #include "base/trace_event/base_tracing.h" |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 18 | |
| 19 | namespace base { |
| 20 | namespace { |
| 21 | |
scottmg | 5e65e3a | 2017-03-08 08:48:46 | [diff] [blame] | 22 | LazyInstance<std::vector<ActionCallback>>::DestructorAtExit g_callbacks = |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 23 | LAZY_INSTANCE_INITIALIZER; |
scottmg | 5e65e3a | 2017-03-08 08:48:46 | [diff] [blame] | 24 | LazyInstance<scoped_refptr<SingleThreadTaskRunner>>::DestructorAtExit |
| 25 | g_task_runner = LAZY_INSTANCE_INITIALIZER; |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 26 | |
| 27 | } // namespace |
| 28 | |
| 29 | void RecordAction(const UserMetricsAction& action) { |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 30 | RecordComputedAction(action.str_); |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 31 | } |
| 32 | |
| 33 | void RecordComputedAction(const std::string& action) { |
bttk | c8a31b70 | 2020-02-25 02:55:17 | [diff] [blame] | 34 | RecordComputedActionAt(action, TimeTicks::Now()); |
| 35 | } |
| 36 | |
bttk | 211b851 | 2020-03-18 04:24:01 | [diff] [blame] | 37 | void RecordComputedActionSince(const std::string& action, |
| 38 | TimeDelta time_since) { |
| 39 | RecordComputedActionAt(action, TimeTicks::Now() - time_since); |
| 40 | } |
| 41 | |
bttk | c8a31b70 | 2020-02-25 02:55:17 | [diff] [blame] | 42 | void RecordComputedActionAt(const std::string& action, TimeTicks action_time) { |
| 43 | TRACE_EVENT_INSTANT1("ui", "UserEvent", TRACE_EVENT_SCOPE_GLOBAL, "action", |
| 44 | action); |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 45 | if (!g_task_runner.Get()) { |
| 46 | DCHECK(g_callbacks.Get().empty()); |
| 47 | return; |
| 48 | } |
| 49 | |
| 50 | if (!g_task_runner.Get()->BelongsToCurrentThread()) { |
bttk | c8a31b70 | 2020-02-25 02:55:17 | [diff] [blame] | 51 | g_task_runner.Get()->PostTask( |
| 52 | FROM_HERE, BindOnce(&RecordComputedActionAt, action, action_time)); |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 53 | return; |
| 54 | } |
| 55 | |
| 56 | for (const ActionCallback& callback : g_callbacks.Get()) { |
bttk | c8a31b70 | 2020-02-25 02:55:17 | [diff] [blame] | 57 | callback.Run(action, action_time); |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 58 | } |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 59 | } |
| 60 | |
| 61 | void AddActionCallback(const ActionCallback& callback) { |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 62 | // Only allow adding a callback if the task runner is set. |
| 63 | DCHECK(g_task_runner.Get()); |
| 64 | DCHECK(g_task_runner.Get()->BelongsToCurrentThread()); |
| 65 | g_callbacks.Get().push_back(callback); |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 66 | } |
| 67 | |
| 68 | void RemoveActionCallback(const ActionCallback& callback) { |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 69 | DCHECK(g_task_runner.Get()); |
| 70 | DCHECK(g_task_runner.Get()->BelongsToCurrentThread()); |
| 71 | std::vector<ActionCallback>* callbacks = g_callbacks.Pointer(); |
Peter Kasting | fea6bb7 | 2022-09-29 16:41:24 | [diff] [blame] | 72 | const auto i = ranges::find(*callbacks, callback); |
Peter Kasting | fc94f506 | 2022-06-08 16:41:45 | [diff] [blame] | 73 | if (i != callbacks->end()) |
| 74 | callbacks->erase(i); |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 75 | } |
[email protected] | abca098 | 2014-04-10 01:12:36 | [diff] [blame] | 76 | |
beaudoin | d5c435e | 2016-04-22 14:17:10 | [diff] [blame] | 77 | void SetRecordActionTaskRunner( |
| 78 | scoped_refptr<SingleThreadTaskRunner> task_runner) { |
| 79 | DCHECK(task_runner->BelongsToCurrentThread()); |
| 80 | DCHECK(!g_task_runner.Get() || g_task_runner.Get()->BelongsToCurrentThread()); |
| 81 | g_task_runner.Get() = task_runner; |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 82 | } |
| 83 | |
ssid | 70aefba4 | 2020-02-04 19:34:03 | [diff] [blame] | 84 | scoped_refptr<SingleThreadTaskRunner> GetRecordActionTaskRunner() { |
| 85 | if (g_task_runner.IsCreated()) |
| 86 | return g_task_runner.Get(); |
| 87 | return nullptr; |
| 88 | } |
| 89 | |
[email protected] | e6e30ac | 2014-01-13 21:24:39 | [diff] [blame] | 90 | } // namespace base |