aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorZac Medico <zmedico@gentoo.org>2020-02-28 23:32:21 -0800
committerZac Medico <zmedico@gentoo.org>2020-02-28 23:47:39 -0800
commitd343bd2eebbb771cb6e43d4e3add85614db6b2a6 (patch)
tree07b8ef5fab02be8bf0f7ca5baab91cd076ceacf8 /lib
parentasyncio: improve _AsyncioEventLoop isinstance logic (diff)
downloadportage-d343bd2eebbb771cb6e43d4e3add85614db6b2a6.tar.gz
portage-d343bd2eebbb771cb6e43d4e3add85614db6b2a6.tar.bz2
portage-d343bd2eebbb771cb6e43d4e3add85614db6b2a6.zip
AsyncFunction: eliminate _pipe_logger_exit with _async_waitpid
Eliminate the _pipe_logger_exit method by overriding the _async_waitpid method. Signed-off-by: Zac Medico <zmedico@gentoo.org>
Diffstat (limited to 'lib')
-rw-r--r--lib/portage/util/_async/AsyncFunction.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/portage/util/_async/AsyncFunction.py b/lib/portage/util/_async/AsyncFunction.py
index 9cfeeeada..bd7e84ea3 100644
--- a/lib/portage/util/_async/AsyncFunction.py
+++ b/lib/portage/util/_async/AsyncFunction.py
@@ -49,10 +49,11 @@ class AsyncFunction(ForkProcess):
return os.EX_OK
- def _pipe_logger_exit(self, pipe_logger):
+ def _async_waitpid(self):
# Ignore this event, since we want to ensure that we exit
# only after _async_func_reader_exit has reached EOF.
- self._pipe_logger = None
+ if self._async_func_reader is None:
+ ForkProcess._async_waitpid(self)
def _async_func_reader_exit(self, pipe_reader):
try: