FEM: solver, move observer def into base class and use decode for Py3 bytestrings
This commit is contained in:
@@ -95,19 +95,6 @@ class Solve(run.Solve):
|
||||
# self._updateOutput(output)
|
||||
del output # get flake8 quiet
|
||||
|
||||
def _observeSolver(self, process):
|
||||
output = ""
|
||||
line = process.stdout.readline()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
while line:
|
||||
line = "\n%s" % line.rstrip()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
return output
|
||||
|
||||
|
||||
class Results(run.Results):
|
||||
|
||||
|
||||
@@ -109,19 +109,6 @@ class Solve(run.Solve):
|
||||
self.report.error("ElmerSolver executable not found.")
|
||||
self.fail()
|
||||
|
||||
def _observeSolver(self, process):
|
||||
output = b""
|
||||
line = process.stdout.readline()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
while line:
|
||||
line = b"\n%s" % line.rstrip()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
return output
|
||||
|
||||
def _updateOutput(self, output):
|
||||
if self.solver.ElmerOutput is None:
|
||||
self._createOutput()
|
||||
|
||||
@@ -296,7 +296,19 @@ class Check(BaseTask):
|
||||
|
||||
|
||||
class Solve(BaseTask):
|
||||
pass
|
||||
|
||||
def _observeSolver(self, process):
|
||||
output = ""
|
||||
line = FemUtils.pydecode(process.stdout.readline())
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = FemUtils.pydecode(process.stdout.readline())
|
||||
while line:
|
||||
line = "\n%s" % line.rstrip()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = FemUtils.pydecode(process.stdout.readline())
|
||||
return output
|
||||
|
||||
|
||||
class Prepare(BaseTask):
|
||||
|
||||
@@ -110,19 +110,6 @@ class Solve(run.Solve):
|
||||
# self._updateOutput(output)
|
||||
del output # get flake8 quiet
|
||||
|
||||
def _observeSolver(self, process):
|
||||
output = ""
|
||||
line = process.stdout.readline()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
while line:
|
||||
line = "\n%s" % line.rstrip()
|
||||
self.pushStatus(line)
|
||||
output += line
|
||||
line = process.stdout.readline()
|
||||
return output
|
||||
|
||||
|
||||
class Results(run.Results):
|
||||
|
||||
|
||||
Reference in New Issue
Block a user