openstack/deb-python-kafka
Code Issues Proposed changes

small bug fix in Sensor

Browse Source 
pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99
This commit is contained in:
Zack Dever
2016-05-03 17:43:50 -07:00
parent 874f4874a7
commit 416f50b6f7
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/metrics/stats/sensor.py
View File

@@ -64,7 +64,7 @@ class Sensor(object):
now = time.time() * 1000 now = time.time() * 1000
if time_ms is None: if time_ms is None:
time_ms = now time_ms = now
self._last_record_time = now self._last_record_time = time_ms
with self._lock: # XXX high volume, might be performance issue with self._lock: # XXX high volume, might be performance issue
# increment all the stats # increment all the stats
for stat in self._stats: for stat in self._stats: