diff options
Diffstat (limited to 'lib/_emerge')
-rw-r--r-- | lib/_emerge/AbstractPollTask.py | 3 | ||||
-rw-r--r-- | lib/_emerge/CompositeTask.py | 3 | ||||
-rw-r--r-- | lib/_emerge/FifoIpcDaemon.py | 3 | ||||
-rw-r--r-- | lib/_emerge/SubProcess.py | 6 |
4 files changed, 1 insertions, 14 deletions
diff --git a/lib/_emerge/AbstractPollTask.py b/lib/_emerge/AbstractPollTask.py index 4157794c6..7e9f2b536 100644 --- a/lib/_emerge/AbstractPollTask.py +++ b/lib/_emerge/AbstractPollTask.py @@ -16,9 +16,6 @@ class AbstractPollTask(AsynchronousTask): _bufsize = 4096 - def isAlive(self): - return bool(self._registered) - def _read_array(self, f): """ NOTE: array.fromfile() is used here only for testing purposes, diff --git a/lib/_emerge/CompositeTask.py b/lib/_emerge/CompositeTask.py index 319f9f995..1d199d19b 100644 --- a/lib/_emerge/CompositeTask.py +++ b/lib/_emerge/CompositeTask.py @@ -12,9 +12,6 @@ class CompositeTask(AsynchronousTask): _TASK_QUEUED = -1 - def isAlive(self): - return self._current_task is not None - def _cancel(self): if self._current_task is not None: if self._current_task is self._TASK_QUEUED: diff --git a/lib/_emerge/FifoIpcDaemon.py b/lib/_emerge/FifoIpcDaemon.py index 0cbaa13c7..2ec69d1cb 100644 --- a/lib/_emerge/FifoIpcDaemon.py +++ b/lib/_emerge/FifoIpcDaemon.py @@ -70,9 +70,6 @@ class FifoIpcDaemon(AbstractPollTask): self._files.pipe_in, self._input_handler) - def isAlive(self): - return self._registered - def _cancel(self): if self.returncode is None: self.returncode = 1 diff --git a/lib/_emerge/SubProcess.py b/lib/_emerge/SubProcess.py index 1ddfe57fd..e834cb7d3 100644 --- a/lib/_emerge/SubProcess.py +++ b/lib/_emerge/SubProcess.py @@ -24,7 +24,7 @@ class SubProcess(AbstractPollTask): return self.returncode def _cancel(self): - if self.isAlive(): + if self.isAlive() and self.pid is not None: try: os.kill(self.pid, signal.SIGTERM) except OSError as e: @@ -37,10 +37,6 @@ class SubProcess(AbstractPollTask): elif e.errno != errno.ESRCH: raise - def isAlive(self): - return self.pid is not None and \ - self.returncode is None - def _async_wait(self): if self.returncode is None: raise asyncio.InvalidStateError('Result is not ready for %s' % (self,)) |