import pipes
import random
import re
+import select
import shutil
import signal
import subprocess
if self.interactive:
self.log.info("%s | Process ID: %d" % (name, self.proc_ident))
- # Communicate returns a tuple of (stdout, stderr), however we always
- # redirect stderr to stdout, so the second element is ignored.
- process_output, _ = self.communicate(proc)
+ if self.pStdout == PIPE:
+ process_stdout = ""
+ while True:
+ (r, w, e) = select.select([proc.stdout], [], [], 120)
+ if len(r) == 0:
+ process_stdout += "TEST-UNEXPECTED-FAIL | %s | application timed out after 120 seconds with no output" % (test)
+ proc.kill()
+ break
+ line = proc.stdout.read(1)
+ if line == "":
+ break
+ process_stdout += line
+ proc.wait()
+ else:
+ # Communicate returns a tuple of (stdout, stderr), however we always
+ # redirect stderr to stdout, so the second element is ignored.
+ process_output, _ = self.communicate(proc)
if self.interactive:
# Not sure what else to do here...