summaryrefslogtreecommitdiffstats
path: root/pym
diff options
context:
space:
mode:
authorZac Medico <zmedico@gentoo.org>2011-12-13 12:01:23 -0800
committerZac Medico <zmedico@gentoo.org>2011-12-13 12:01:23 -0800
commit4d9c153df82200d76684b6a9de69994c5f325971 (patch)
treeee33a23cce49e6d8c2b838ba7640faa2c85acfb5 /pym
parenta628147b632ad8b33296f5698d30410854cf1d75 (diff)
downloadportage-4d9c153df82200d76684b6a9de69994c5f325971.tar.gz
portage-4d9c153df82200d76684b6a9de69994c5f325971.tar.bz2
portage-4d9c153df82200d76684b6a9de69994c5f325971.zip
FifoIpcDaemon: use plain fd instead of fdopen
Diffstat (limited to 'pym')
-rw-r--r--pym/_emerge/FifoIpcDaemon.py16
1 files changed, 8 insertions, 8 deletions
diff --git a/pym/_emerge/FifoIpcDaemon.py b/pym/_emerge/FifoIpcDaemon.py
index a716dac7c..b1f7a9569 100644
--- a/pym/_emerge/FifoIpcDaemon.py
+++ b/pym/_emerge/FifoIpcDaemon.py
@@ -15,14 +15,14 @@ class FifoIpcDaemon(AbstractPollTask):
def _start(self):
self._files = self._files_dict()
- input_fd = os.open(self.input_fifo, os.O_RDONLY|os.O_NONBLOCK)
# File streams are in unbuffered mode since we do atomic
# read and write of whole pickles.
- self._files.pipe_in = os.fdopen(input_fd, 'rb', 0)
+ self._files.pipe_in = \
+ os.open(self.input_fifo, os.O_RDONLY|os.O_NONBLOCK)
self._reg_id = self.scheduler.register(
- self._files.pipe_in.fileno(),
+ self._files.pipe_in,
self._registered_events, self._input_handler)
self._registered = True
@@ -32,12 +32,12 @@ class FifoIpcDaemon(AbstractPollTask):
Re-open the input stream, in order to suppress
POLLHUP events (bug #339976).
"""
- self._files.pipe_in.close()
- input_fd = os.open(self.input_fifo, os.O_RDONLY|os.O_NONBLOCK)
- self._files.pipe_in = os.fdopen(input_fd, 'rb', 0)
self.scheduler.unregister(self._reg_id)
+ os.close(self._files.pipe_in)
+ self._files.pipe_in = \
+ os.open(self.input_fifo, os.O_RDONLY|os.O_NONBLOCK)
self._reg_id = self.scheduler.register(
- self._files.pipe_in.fileno(),
+ self._files.pipe_in,
self._registered_events, self._input_handler)
def isAlive(self):
@@ -77,5 +77,5 @@ class FifoIpcDaemon(AbstractPollTask):
if self._files is not None:
for f in self._files.values():
- f.close()
+ os.close(f)
self._files = None