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

move all temp files to artifacts_base_dir

Browse Source
This commit is contained in:
Andrey Pohilko 2012-09-21 15:35:19 +04:00
parent 8334b80426
commit f282a03c3b
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Tank/Plugins/ApacheBenchmark.py
View File

@ -25,7 +25,7 @@ class ApacheBenchmarkPlugin(AbstractPlugin):
self.url = self.get_option("url", 'http://localhost/')
self.requests = self.get_option("requests", '100')
self.concurrency = self.get_option("concurrency", '1')
self.out_file = tempfile.mkstemp('.log', 'ab_')[1]
self.out_file = tempfile.mkstemp('.log', 'ab_', self.core.artifacts_base_dir)[1]
self.core.add_artifact_file(self.out_file)
def prepare_test(self):

2
Tank/Plugins/Monitoring.py
View File

@ -54,7 +54,7 @@ class MonitoringPlugin(AbstractPlugin):
if self.default_target:
self.monitoring.default_target = self.default_target
data_file = tempfile.mkstemp('.data', 'monitoring_')[1]
data_file = tempfile.mkstemp('.data', 'monitoring_', self.core.artifacts_base_dir)[1]
self.monitoring.add_listener(SaveMonToFile(data_file))
self.core.add_artifact_file(data_file)

10
Tank/Plugins/Phantom.py
View File

@ -116,7 +116,7 @@ class PhantomPlugin(AbstractPlugin):
self.address = self.get_option(self.OPTION_IP, '127.0.0.1')
self.port = self.get_option(self.OPTION_PORT, '80')
self.tank_type = self.get_option("tank_type", 'http')
self.answ_log = self.get_option("answ_log", tempfile.mkstemp(".log", "answ_")[1])
self.answ_log = self.get_option("answ_log", tempfile.mkstemp(".log", "answ_", self.core.artifacts_base_dir)[1])
self.answ_log_level = self.get_option("writelog", "none")
if self.answ_log_level == '0':
self.answ_log_level = 'none'
@ -124,12 +124,12 @@ class PhantomPlugin(AbstractPlugin):
self.answ_log_level = 'all'
self.phout_file = self.get_option("phout_file", '')
if not self.phout_file:
self.phout_file = tempfile.mkstemp(".log", "phout_")[1]
self.phout_file = tempfile.mkstemp(".log", "phout_", self.core.artifacts_base_dir)[1]
self.core.add_artifact_file(self.phout_file)
else:
self.phout_import_mode = 1
self.stat_log = self.get_option("stat_log", tempfile.mkstemp(".log", "phantom_stat_")[1])
self.phantom_log = self.get_option("phantom_log", tempfile.mkstemp(".log", "phantom_")[1])
self.stat_log = self.get_option("stat_log", tempfile.mkstemp(".log", "phantom_stat_", self.core.artifacts_base_dir)[1])
self.phantom_log = self.get_option("phantom_log", tempfile.mkstemp(".log", "phantom_", self.core.artifacts_base_dir)[1])
self.stpd = self.get_option(self.OPTION_STPD, '')
self.threads = self.get_option("threads", int(multiprocessing.cpu_count() / 2) + 1)
self.instances = int(self.get_option(self.OPTION_INSTANCES_LIMIT, '1000'))
@ -187,7 +187,7 @@ class PhantomPlugin(AbstractPlugin):
kwargs['reply_limits'] = ''
handle, filename = tempfile.mkstemp(".conf", "phantom_")
handle, filename = tempfile.mkstemp(".conf", "phantom_", self.core.artifacts_base_dir)
self.core.add_artifact_file(filename)
self.log.debug("Generating phantom config: %s", filename)
template_str = open(os.path.dirname(__file__) + "/phantom.conf.tpl", 'r').read()