diff options
author | Zac Medico <zmedico@gentoo.org> | 2012-02-09 17:27:13 -0800 |
---|---|---|
committer | Zac Medico <zmedico@gentoo.org> | 2012-02-09 17:27:13 -0800 |
commit | c85b1d7149f09e64b5ed4f5e45742b6e5a9df38b (patch) | |
tree | 89acfdef9a210a4a179eff28806cb3094362c0e1 /pym/_emerge/AsynchronousLock.py | |
parent | 963fa653fc0d7aff25bb4756df8398b88193547c (diff) | |
download | portage-c85b1d7149f09e64b5ed4f5e45742b6e5a9df38b.tar.gz portage-c85b1d7149f09e64b5ed4f5e45742b6e5a9df38b.tar.bz2 portage-c85b1d7149f09e64b5ed4f5e45742b6e5a9df38b.zip |
Use IO_* constants where appropriate.
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: |