diff options
Diffstat (limited to 'lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/internet/_baseprocess.py')
-rwxr-xr-x | lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/internet/_baseprocess.py | 62 |
1 files changed, 0 insertions, 62 deletions
diff --git a/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/internet/_baseprocess.py b/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/internet/_baseprocess.py deleted file mode 100755 index 0a06259b..00000000 --- a/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/internet/_baseprocess.py +++ /dev/null @@ -1,62 +0,0 @@ -# -*- test-case-name: twisted.test.test_process -*- -# Copyright (c) Twisted Matrix Laboratories. -# See LICENSE for details. - -""" -Cross-platform process-related functionality used by different -L{IReactorProcess} implementations. -""" - -from twisted.python.reflect import qual -from twisted.python.deprecate import getWarningMethod -from twisted.python.failure import Failure -from twisted.python.log import err -from twisted.persisted.styles import Ephemeral - -_missingProcessExited = ("Since Twisted 8.2, IProcessProtocol.processExited " - "is required. %s must implement it.") - -class BaseProcess(Ephemeral): - pid = None - status = None - lostProcess = 0 - proto = None - - def __init__(self, protocol): - self.proto = protocol - - - def _callProcessExited(self, reason): - default = object() - processExited = getattr(self.proto, 'processExited', default) - if processExited is default: - getWarningMethod()( - _missingProcessExited % (qual(self.proto.__class__),), - DeprecationWarning, stacklevel=0) - else: - processExited(Failure(reason)) - - - def processEnded(self, status): - """ - This is called when the child terminates. - """ - self.status = status - self.lostProcess += 1 - self.pid = None - self._callProcessExited(self._getReason(status)) - self.maybeCallProcessEnded() - - - def maybeCallProcessEnded(self): - """ - Call processEnded on protocol after final cleanup. - """ - if self.proto is not None: - reason = self._getReason(self.status) - proto = self.proto - self.proto = None - try: - proto.processEnded(Failure(reason)) - except: - err(None, "unexpected error in processEnded") |