client/third_party/infra_libs/ts_mon/common/metric_store.py - Issue 2465423002: Roll infra_libs to 564aaf7480f24c90687df79d9cef910cc342a54d

Keyboard Shortcuts

	File
u :	up to issue
j / k :	jump to file after / before current file
J / K :	jump to next file with a comment after / before current file
	Side-by-side diff
i :	toggle intra-line diffs
e :	expand all comments
c :	collapse all comments
s :	toggle showing all comments
n / p :	next / previous diff chunk or comment
N / P :	next / previous comment
<Up> / <Down> :	next / previous line

	Issue
u :	up to list of issues
j / k :	jump to patch after / before current patch
o / <Enter> :	open current patch in side-by-side view
i :	open current patch in unified diff view

	Issue List
j / k :	jump to issue after / before current issue
o / <Enter> :	open current issue

Unified Diff: client/third_party/infra_libs/ts_mon/common/metric_store.py

Issue 2465423002: Roll infra_libs to 564aaf7480f24c90687df79d9cef910cc342a54d (Closed)

Patch Set: update readmes Created 4 years, 1 month ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

Index: client/third_party/infra_libs/ts_mon/common/metric_store.py

diff --git a/client/third_party/infra_libs/ts_mon/common/metric_store.py b/client/third_party/infra_libs/ts_mon/common/metric_store.py

index 4d21feeabd964d1a1a1354f0f77bbab14eb355d9..1675bf0fe9f8299fd9aa95b279dc63718ae4892a 100644

--- a/client/third_party/infra_libs/ts_mon/common/metric_store.py

+++ b/client/third_party/infra_libs/ts_mon/common/metric_store.py

@@ -257,13 +257,15 @@ class InProcessMetricStore(MetricStore):

# generator's consumer) modifies them while we're iterating.

with self._thread_lock:

values = copy.copy(self._values)

+ end_time = self._time_fn()

for name, metric_values in values.iteritems():

if name not in self._state.metrics:

continue

start_time = metric_values.start_time

for target, fields_values in metric_values.values.iter_targets():

- yield target, self._state.metrics[name], start_time, fields_values

+ yield (target, self._state.metrics[name], start_time, end_time,

+ fields_values)

def set(self, name, fields, target_fields, value, enforce_ge=False):

with self._thread_lock: