summaryrefslogtreecommitdiffstats
path: root/pym/_emerge/__init__.py
diff options
context:
space:
mode:
authorZac Medico <zmedico@gentoo.org>2008-07-01 10:11:10 +0000
committerZac Medico <zmedico@gentoo.org>2008-07-01 10:11:10 +0000
commit3ab46b943befdd480b24c3d459555011dd04e120 (patch)
tree193103aecbe731acbd022d2f11be38fb9bf8afbb /pym/_emerge/__init__.py
parent43833b58736bef2565250f3965a22ab747ba6d0b (diff)
downloadportage-3ab46b943befdd480b24c3d459555011dd04e120.tar.gz
portage-3ab46b943befdd480b24c3d459555011dd04e120.tar.bz2
portage-3ab46b943befdd480b24c3d459555011dd04e120.zip
Add a "prefix" keyword parameter to slot_dict_class() which controls the
prefix used when mapping attribute names from keys. Use this to change the syntax from files["foo"] to files.foo (it's fewer characters to look at). svn path=/main/trunk/; revision=10869
Diffstat (limited to 'pym/_emerge/__init__.py')
-rw-r--r--pym/_emerge/__init__.py58
1 files changed, 29 insertions, 29 deletions
diff --git a/pym/_emerge/__init__.py b/pym/_emerge/__init__.py
index 9aea4415f..51bb2fddc 100644
--- a/pym/_emerge/__init__.py
+++ b/pym/_emerge/__init__.py
@@ -1459,7 +1459,7 @@ class EbuildFetcherAsync(SlotObject):
"pid", "returncode", "files")
_file_names = ("fetcher", "out")
- _files_dict = slot_dict_class(_file_names)
+ _files_dict = slot_dict_class(_file_names, prefix="")
_bufsize = 4096
def start(self):
@@ -1477,7 +1477,7 @@ class EbuildFetcherAsync(SlotObject):
files = self.files
if log_file is not None:
- files["out"] = open(log_file, "a")
+ files.out = open(log_file, "a")
portage.util.apply_secpass_permissions(log_file,
uid=portage.portage_uid, gid=portage.portage_gid,
mode=0660)
@@ -1488,7 +1488,7 @@ class EbuildFetcherAsync(SlotObject):
if fd == sys.stderr.fileno():
sys.stderr.flush()
- files["out"] = os.fdopen(os.dup(fd_pipes[1]), 'w')
+ files.out = os.fdopen(os.dup(fd_pipes[1]), 'w')
master_fd, slave_fd = os.pipe()
@@ -1526,22 +1526,22 @@ class EbuildFetcherAsync(SlotObject):
self.pid = retval[0]
os.close(slave_fd)
- files["fetcher"] = os.fdopen(master_fd, 'r')
- self.register(files["fetcher"].fileno(),
+ files.fetcher = os.fdopen(master_fd, 'r')
+ self.register(files.fetcher.fileno(),
select.POLLIN, self._output_handler)
def _output_handler(self, fd, event):
files = self.files
buf = array.array('B')
try:
- buf.fromfile(files["fetcher"], self._bufsize)
+ buf.fromfile(files.fetcher, self._bufsize)
except EOFError:
pass
if buf:
- buf.tofile(files["out"])
- files["out"].flush()
+ buf.tofile(files.out)
+ files.out.flush()
else:
- self.unregister(files["fetcher"].fileno())
+ self.unregister(files.fetcher.fileno())
for f in files.values():
f.close()
@@ -1710,7 +1710,7 @@ class EbuildPhase(SlotObject):
"pid", "returncode", "files")
_file_names = ("log", "stdout", "ebuild")
- _files_dict = slot_dict_class(_file_names)
+ _files_dict = slot_dict_class(_file_names, prefix="")
_bufsize = 4096
def start(self):
@@ -1785,26 +1785,26 @@ class EbuildPhase(SlotObject):
if logfile:
os.close(slave_fd)
- files["log"] = open(logfile, 'a')
- files["stdout"] = os.fdopen(os.dup(fd_pipes_orig[1]), 'w')
- files["ebuild"] = os.fdopen(master_fd, 'r')
- self.register(files["ebuild"].fileno(),
+ files.log = open(logfile, 'a')
+ files.stdout = os.fdopen(os.dup(fd_pipes_orig[1]), 'w')
+ files.ebuild = os.fdopen(master_fd, 'r')
+ self.register(files.ebuild.fileno(),
select.POLLIN, self._output_handler)
def _output_handler(self, fd, event):
files = self.files
buf = array.array('B')
try:
- buf.fromfile(files["ebuild"], self._bufsize)
+ buf.fromfile(files.ebuild, self._bufsize)
except EOFError:
pass
if buf:
- buf.tofile(files["stdout"])
- files["stdout"].flush()
- buf.tofile(files["log"])
- files["log"].flush()
+ buf.tofile(files.stdout)
+ files.stdout.flush()
+ buf.tofile(files.log)
+ files.log.flush()
else:
- self.unregister(files["ebuild"].fileno())
+ self.unregister(files.ebuild.fileno())
for f in files.values():
f.close()
@@ -2002,7 +2002,7 @@ class BinpkgFetcherAsync(SlotObject):
"locked", "files", "pid", "pkg_path", "returncode", "_lock_obj")
_file_names = ("fetcher", "out")
- _files_dict = slot_dict_class(_file_names)
+ _files_dict = slot_dict_class(_file_names, prefix="")
_bufsize = 4096
def __init__(self, **kwargs):
@@ -2029,7 +2029,7 @@ class BinpkgFetcherAsync(SlotObject):
files = self.files
if log_file is not None:
- files["out"] = open(log_file, "a")
+ files.out = open(log_file, "a")
portage.util.apply_secpass_permissions(log_file,
uid=portage.portage_uid, gid=portage.portage_gid,
mode=0660)
@@ -2041,7 +2041,7 @@ class BinpkgFetcherAsync(SlotObject):
if fd == sys.stderr.fileno():
sys.stderr.flush()
- files["out"] = os.fdopen(os.dup(fd_pipes[1]), 'w')
+ files.out = os.fdopen(os.dup(fd_pipes[1]), 'w')
master_fd, slave_fd = os.pipe()
fcntl.fcntl(master_fd, fcntl.F_SETFL,
@@ -2100,22 +2100,22 @@ class BinpkgFetcherAsync(SlotObject):
self.pid = retval[0]
os.close(slave_fd)
- files["fetcher"] = os.fdopen(master_fd, 'r')
- self.register(files["fetcher"].fileno(),
+ files.fetcher = os.fdopen(master_fd, 'r')
+ self.register(files.fetcher.fileno(),
select.POLLIN, self._output_handler)
def _output_handler(self, fd, event):
files = self.files
buf = array.array('B')
try:
- buf.fromfile(files["fetcher"], self._bufsize)
+ buf.fromfile(files.fetcher, self._bufsize)
except EOFError:
pass
if buf:
- buf.tofile(files["out"])
- files["out"].flush()
+ buf.tofile(files.out)
+ files.out.flush()
else:
- self.unregister(files["fetcher"].fileno())
+ self.unregister(files.fetcher.fileno())
for f in files.values():
f.close()
if self.locked: