openstack/zaqar
Code Issues Proposed changes

Merge "In benchmark observer worker, include claimed messages when listing"

Browse Source
This commit is contained in:
Jenkins 2014-09-04 23:49:51 +00:00 committed by Gerrit Code Review
commit 89ee4ce263
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
zaqar/bench/observer.py
View File

@ -70,7 +70,8 @@ def observer(queues, stats, test_duration, limit):
try:
marktime.start('list_messages')
cursor = queue['q'].messages(limit=limit, marker=queue['m'])
cursor = queue['q'].messages(limit=limit, marker=queue['m'],
include_claimed=True)
total_elapsed += marktime.stop('list_messages').seconds
total_succeeded += 1