openstack/deb-python-kafka
Code Issues Proposed changes

Increase fixture wait timeout to 30s; add wait-time logging

Browse Source
This commit is contained in:
Dana Powers
2014-08-13 09:47:03 -07:00
parent 4796d58792
commit a6200f2e99
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/service.py
View File

@@ -80,7 +80,7 @@ class SpawnedService(threading.Thread):
for line in self.captured_stdout: for line in self.captured_stdout:
logging.critical(line.rstrip()) logging.critical(line.rstrip())
def wait_for(self, pattern, timeout=10): def wait_for(self, pattern, timeout=30):
t1 = time.time() t1 = time.time()
while True: while True:
t2 = time.time() t2 = time.time()
@@ -91,11 +91,13 @@ class SpawnedService(threading.Thread):
logging.exception("Received exception when killing child process") logging.exception("Received exception when killing child process")
self.dump_logs() self.dump_logs()
raise RuntimeError("Waiting for %r timed out" % pattern) raise RuntimeError("Waiting for %r timed out after %d seconds" % (pattern, timeout))
if re.search(pattern, '\n'.join(self.captured_stdout), re.IGNORECASE) is not None: if re.search(pattern, '\n'.join(self.captured_stdout), re.IGNORECASE) is not None:
logging.info("Found pattern %r in %d seconds via stdout", pattern, (t2 - t1))
return return
if re.search(pattern, '\n'.join(self.captured_stderr), re.IGNORECASE) is not None: if re.search(pattern, '\n'.join(self.captured_stderr), re.IGNORECASE) is not None:
logging.info("Found pattern %r in %d seconds via stderr", pattern, (t2 - t1))
return return
time.sleep(0.1) time.sleep(0.1)