import reporters
import ConfigParser
import loggable
-import tempfile
from loggable import Loggable
import xml.etree.ElementTree as ET
self.process = None
self.duration = duration
- self.clean(True)
-
- def clean(self, full=True):
- if not full:
- return
+ self.clean()
+ def clean(self):
self.message = ""
self.error_str = ""
self.time_taken = 0.0
self.scenario = scenario
def get_subproc_env(self):
+ self.validatelogs = self.logfile + '.validate.logs'
+ logfiles = self.validatelogs
if self.options.redirect_logs:
- self.validatelogs = os.path.join(
- tempfile.gettempdir(), 'tmp.validate.logs')
- logfiles = self.validatelogs
logfiles += os.pathsep + \
- self.reporter.out.name.replace("<", '').replace(">", '')
- else:
- self.validatelogs = self.logfile + '.validate.logs'
- logfiles = self.validatelogs
+ self.options.redirect_logs.replace("<", '').replace(">", '')
subproc_env = os.environ.copy()
subproc_env["GST_VALIDATE_FILE"] = logfiles
self.extra_logfiles.append(self.validatelogs)
- if 'GST_DEBUG' in os.environ and \
- not self.options.redirect_logs:
+ if 'GST_DEBUG' in os.environ:
gstlogsfile = self.logfile + '.gstdebug'
self.extra_logfiles.append(gstlogsfile)
subproc_env["GST_DEBUG_FILE"] = gstlogsfile
return subproc_env
- def clean(self, full=True):
- Test.clean(self, full=full)
- if hasattr(self, 'validatelogs') and not self.options.redirect_logs:
- try:
- os.remove(self.validatelogs)
- except OSError:
- pass
-
- if full:
- self._sent_eos_pos = None
+ def clean(self):
+ Test.clean(self)
+ self._sent_eos_pos = None
def build_arguments(self):
if "GST_VALIDATE" in os.environ:
self.reporter.after_test()
if res != Result.PASSED and (self.options.forever or
self.options.fatal_error):
- test.clean(full=False)
return test.result
return Result.PASSED
"""
scenarios = []
scenario_defs = os.path.join(self.config.main_dir, "scenarios.def")
- if self.config.redirect_logs:
- logs = open(os.devnull)
- else:
- logs = open(
- os.path.join(self.config.logsdir, "scenarios_discovery.log"), 'w')
+ logs = open(os.path.join(self.config.logsdir,
+ "scenarios_discovery.log"), 'w')
try:
command = [self.GST_VALIDATE_COMMAND,
import loggable
import subprocess
import sys
-import tempfile
logcat = "httpserver"
def start(self):
""" Start the server in a subprocess """
- if self.options.redirect_logs:
- self.info("Using devnull as HTTP server log file")
- self._logsfile = tempfile.TemporaryFile()
- else:
- self._logsfile = open(os.path.join(self.options.logsdir,
- "httpserver.logs"),
- 'w+')
+ self._logsfile = open(os.path.join(self.options.logsdir,
+ "httpserver.logs"), 'w+')
if self.options.http_server_dir is not None:
if self._check_is_up(timeout=2):
return True
def before_test(self, test):
"""Initialize a timer before starting a test."""
+ path = os.path.join(self.options.logsdir,
+ test.classname.replace(".", os.sep))
+ mkdir(os.path.dirname(path))
+ test.logfile = path
+
if self.options.redirect_logs == 'stdout':
self.out = sys.stdout
- test.logfile = 'stdout'
elif self.options.redirect_logs == 'stderr':
self.out = sys.stderr
- test.logfile = 'stderr'
else:
- path = os.path.join(self.options.logsdir,
- test.classname.replace(".", os.sep))
- mkdir(os.path.dirname(path))
self.out = open(path, 'w+')
- test.logfile = path
self._current_test = test
if self._start_time == 0: