openstack/deb-python-kafka
Code Issues Proposed changes

Merge pull request #679 from zackdever/kafka-PR-1265-bugfix

Browse Source 
small bug fix in Sensor
This commit is contained in:
Zack Dever
2016-05-03 18:21:14 -07:00
parent d401bde9ed 416f50b6f7
commit 0684302d8f
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
if time_ms is None:
time_ms = now
self._last_record_time = now
self._last_record_time = time_ms
with self._lock: # XXX high volume, might be performance issue
# increment all the stats
for stat in self._stats: