self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addError(self._current_test, RemoteError(""))
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addError(self._current_test, RemoteError(""))
self._current_test = None
elif (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description + " [" == line[offset:-1]):
self._current_test = None
elif (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description + " [" == line[offset:-1]):
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addFailure(self._current_test, RemoteError())
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addFailure(self._current_test, RemoteError())
elif (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description + " [" == line[offset:-1]):
self.state = TestProtocolServer.READING_FAILURE
elif (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description + " [" == line[offset:-1]):
self.state = TestProtocolServer.READING_FAILURE
if (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description == line[offset:-1]):
self.client.addSuccess(self._current_test)
if (self.state == TestProtocolServer.TEST_STARTED and
self.current_test_description == line[offset:-1]):
self.client.addSuccess(self._current_test)
self.current_test_description = None
self._current_test = None
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self._current_test = None
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addFailure(self._current_test,
RemoteError(self._message))
self.current_test_description = None
self.client.addFailure(self._current_test,
RemoteError(self._message))
elif self.state == TestProtocolServer.READING_ERROR:
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addError(self._current_test,
RemoteError(self._message))
elif self.state == TestProtocolServer.READING_ERROR:
self.state = TestProtocolServer.OUTSIDE_TEST
self.current_test_description = None
self.client.addError(self._current_test,
RemoteError(self._message))
self.client.addError(self._current_test,
RemoteError("lost connection during test '%s'"
% self.current_test_description))
self.client.addError(self._current_test,
RemoteError("lost connection during test '%s'"
% self.current_test_description))
elif self.state == TestProtocolServer.READING_ERROR:
self.client.addError(self._current_test,
RemoteError("lost connection during "
"error report of test "
"'%s'" %
self.current_test_description))
elif self.state == TestProtocolServer.READING_ERROR:
self.client.addError(self._current_test,
RemoteError("lost connection during "
"error report of test "
"'%s'" %
self.current_test_description))
elif self.state == TestProtocolServer.READING_FAILURE:
self.client.addError(self._current_test,
RemoteError("lost connection during "
"failure report of test "
"'%s'" %
self.current_test_description))
elif self.state == TestProtocolServer.READING_FAILURE:
self.client.addError(self._current_test,
RemoteError("lost connection during "
"failure report of test "
"'%s'" %
self.current_test_description))
def readFrom(self, pipe):
for line in pipe.readlines(pipe):
def readFrom(self, pipe):
for line in pipe.readlines(pipe):