valitydev/yandex-tank
14
0
Fork 0
mirror of https://github.com/valitydev/yandex-tank.git synced 2024-11-06 10:25:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Cosmetics

Browse Source
This commit is contained in:
Andrey Pohilko 2012-10-02 11:46:17 +04:00
parent 5499be589a
commit cc84d9cf64
3 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Tank/Plugins/ConsoleScreen.py
View File

@ -462,6 +462,7 @@ class AnswSizesBlock(AbstractBlock):
self.sum_out = 0
self.count = 0
self.header = screen.markup.WHITE + 'Request/Response Sizes:' + screen.markup.RESET
self.cur_count = 0
def render(self):
self.lines = [self.header]
@ -469,6 +470,7 @@ class AnswSizesBlock(AbstractBlock):
self.lines.append(" Avg Request at %s RPS: %d bytes" % (self.current_rps, self.sum_out / self.count))
self.lines.append(" Avg Response at %s RPS: %d bytes" % (self.current_rps, self.sum_in / self.count))
self.lines.append("")
if self.cur_count:
self.lines.append(" Last Avg Request: %d bytes" % (self.cur_out / self.cur_count))
self.lines.append(" Last Avg Response: %d bytes" % (self.cur_in / self.cur_count))
for line in self.lines:

5
Tank/Plugins/Loadosophia.py
View File

@ -6,13 +6,13 @@ from Tank.Plugins.ApacheBenchmark import ApacheBenchmarkPlugin
from Tank.Plugins.Monitoring import MonitoringPlugin
from Tank.Plugins.Phantom import PhantomPlugin
import StringIO
import gzip
import itertools
import logging
import mimetools
import mimetypes
import os
import urllib2
import gzip
class LoadosophiaPlugin(AbstractPlugin):
'''
@ -66,6 +66,7 @@ class LoadosophiaPlugin(AbstractPlugin):
self.loadosophia.send_results(self.project_key, main_file, [mon_file])
return retcode
class LoadosophiaClient:
def __init__(self):
self.log = logging.getLogger(__name__)
@ -197,3 +198,5 @@ class MultiPartForm(object):
flattened.append('--' + self.boundary + '--')
flattened.append('')
return '\r\n'.join(flattened)

1
Tank/Plugins/Phantom.py
View File

@ -681,7 +681,6 @@ class PhantomReader(AbstractReader):
'''
Mark second with expected rps from stepper info
'''
# TODO: 3 optimize expected rps with rolling property
offset = next_time - self.first_request_time
for rps, dur in Utils.pairs(self.phantom.steps):
if offset < dur: