aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'lib/_emerge')
-rw-r--r--lib/_emerge/AbstractPollTask.py3
-rw-r--r--lib/_emerge/CompositeTask.py3
-rw-r--r--lib/_emerge/FifoIpcDaemon.py3
-rw-r--r--lib/_emerge/SubProcess.py6
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,))