openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "Simulator: align stats to whole seconds"

This commit is contained in:
Jenkins 2016-05-05 03:22:05 +00:00 committed by Gerrit Code Review
parent 2a6f7c5910 782ab770cf
commit e2b57bb590
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tools/simulator.py
View File

@ -116,7 +116,10 @@ class MessageStatsCollector(object):
self.label = label
self.buffer = [] # buffer to store messages during report interval
self.series = [] # stats for every report interval
threading.Timer(1.0, self.monitor).start() # schedule in a second
now = time.time()
diff = int(now) - now + 1 # align start to whole seconds
threading.Timer(diff, self.monitor).start() # schedule in a second
def monitor(self):
global IS_RUNNING
@ -440,6 +443,11 @@ def send_messages(client_id, client_builder, messages_count, duration):
client = client_builder()
CLIENTS.append(client)
# align message sending closer to whole seconds
now = time.time()
diff = int(now) - now + 1
time.sleep(diff)
if duration:
with timeutils.StopWatch(duration) as stop_watch:
while not stop_watch.expired() and IS_RUNNING: