if buf:
self._read_data.append(buf.tostring())
else:
- for f in files.values():
- f.close()
self.registered = False
for reg_id in self._reg_ids:
self.scheduler.unregister(reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
return self.registered
buf.tofile(files.out)
files.out.flush()
else:
- fd = files.process.fileno()
- for f in files.values():
- f.flush()
- f.close()
self.registered = False
self.scheduler.unregister(self._reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
return self.registered
if buf:
pass
else:
- fd = files.process.fileno()
- for f in files.values():
- f.close()
self.registered = False
self.scheduler.unregister(self._reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
return self.registered
files = self.files
self._raw_metadata.append(files.ebuild.read())
if not self._raw_metadata[-1]:
- for f in files.values():
- f.close()
self.registered = False
self.scheduler.unregister(self._reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
if self.returncode == os.EX_OK:
buf.tofile(files.log)
files.log.flush()
else:
- fd = files.ebuild.fileno()
- for f in files.values():
- f.close()
self.registered = False
self.scheduler.unregister(self._reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
return self.registered
if buf:
pass
else:
- fd = files.ebuild.fileno()
- for f in files.values():
- f.close()
self.registered = False
self.scheduler.unregister(self._reg_id)
+
+ for f in files.values():
+ f.close()
+
self.wait()
return self.registered