diff options
Diffstat (limited to 'pym/_emerge/AsynchronousLock.py')
| -rw-r--r-- | pym/_emerge/AsynchronousLock.py | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/pym/_emerge/AsynchronousLock.py b/pym/_emerge/AsynchronousLock.py index 3cf0acbd5..c07df0bdd 100644 --- a/pym/_emerge/AsynchronousLock.py +++ b/pym/_emerge/AsynchronousLock.py @@ -20,7 +20,6 @@ from portage.locks import lockfile, unlockfile from portage.util import writemsg_level from _emerge.AbstractPollTask import AbstractPollTask from _emerge.AsynchronousTask import AsynchronousTask -from _emerge.PollConstants import PollConstants from _emerge.SpawnProcess import SpawnProcess class AsynchronousLock(AsynchronousTask): @@ -118,7 +117,7 @@ class _LockThread(AbstractPollTask): fcntl.fcntl(f, fcntl.F_SETFL, fcntl.fcntl(f, fcntl.F_GETFL) | os.O_NONBLOCK) self._reg_id = self.scheduler.register(self._files['pipe_read'], - PollConstants.POLLIN, self._output_handler) + self.scheduler.IO_IN, self._output_handler) self._registered = True threading_mod = threading if self._force_dummy: @@ -132,7 +131,7 @@ class _LockThread(AbstractPollTask): def _output_handler(self, f, event): buf = None - if event & PollConstants.POLLIN: + if event & self.scheduler.IO_IN: try: buf = os.read(self._files['pipe_read'], self._bufsize) except OSError as e: @@ -200,7 +199,7 @@ class _LockProcess(AbstractPollTask): fcntl.fcntl(in_pr, fcntl.F_SETFL, fcntl.fcntl(in_pr, fcntl.F_GETFL) | os.O_NONBLOCK) self._reg_id = self.scheduler.register(in_pr, - PollConstants.POLLIN, self._output_handler) + self.scheduler.IO_IN, self._output_handler) self._registered = True self._proc = SpawnProcess( args=[portage._python_interpreter, @@ -268,7 +267,7 @@ class _LockProcess(AbstractPollTask): def _output_handler(self, f, event): buf = None - if event & PollConstants.POLLIN: + if event & self.scheduler.IO_IN: try: buf = os.read(self._files['pipe_in'], self._bufsize) except OSError as e: |