OLD | NEW |
---|---|
1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 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 """Classes representing the monitoring interface for tasks or devices. | 5 """Classes representing the monitoring interface for tasks or devices. |
6 | 6 |
7 Usage: | 7 Usage: |
8 import argparse | 8 import argparse |
9 from infra_libs import ts_mon | 9 from infra_libs import ts_mon |
10 | 10 |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
70 # The background thread that flushes metrics every | 70 # The background thread that flushes metrics every |
71 # --ts-mon-flush-interval-secs seconds. May be None if | 71 # --ts-mon-flush-interval-secs seconds. May be None if |
72 # --ts-mon-flush != 'auto' or --ts-mon-flush-interval-secs == 0. | 72 # --ts-mon-flush != 'auto' or --ts-mon-flush-interval-secs == 0. |
73 self.flush_thread = None | 73 self.flush_thread = None |
74 # All metrics created by this application. | 74 # All metrics created by this application. |
75 self.metrics = {} | 75 self.metrics = {} |
76 # The MetricStore object that holds the actual metric values. | 76 # The MetricStore object that holds the actual metric values. |
77 self.store = store_ctor(self) | 77 self.store = store_ctor(self) |
78 # Cached time of the last flush. Useful mostly in AppEngine apps. | 78 # Cached time of the last flush. Useful mostly in AppEngine apps. |
79 self.last_flushed = datetime.datetime.utcfromtimestamp(0) | 79 self.last_flushed = datetime.datetime.utcfromtimestamp(0) |
80 # Metric name prefix | |
81 self.metric_name_prefix = '/chrome/infra' | |
Sergey Berezin
2016/07/06 17:49:12
'/chrome/infra/' (trailing slash). This may or may
| |
80 | 82 |
81 def reset_for_unittest(self): | 83 def reset_for_unittest(self): |
82 self.metrics = {} | 84 self.metrics = {} |
83 self.last_flushed = datetime.datetime.utcfromtimestamp(0) | 85 self.last_flushed = datetime.datetime.utcfromtimestamp(0) |
84 self.store.reset_for_unittest() | 86 self.store.reset_for_unittest() |
85 | 87 |
86 state = State() | 88 state = State() |
87 | 89 |
88 | 90 |
89 def flush(): | 91 def flush(): |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
185 'Last monitoring flush took %f seconds (longer than ' | 187 'Last monitoring flush took %f seconds (longer than ' |
186 '--ts-mon-flush-interval-secs = %f seconds)', | 188 '--ts-mon-flush-interval-secs = %f seconds)', |
187 flush_duration, self.interval_secs) | 189 flush_duration, self.interval_secs) |
188 next_timeout = 0 | 190 next_timeout = 0 |
189 | 191 |
190 def stop(self): | 192 def stop(self): |
191 """Stops the background thread and performs a final flush.""" | 193 """Stops the background thread and performs a final flush.""" |
192 | 194 |
193 self.stop_event.set() | 195 self.stop_event.set() |
194 self.join() | 196 self.join() |
OLD | NEW |