(self)
| 4034 | self.gitStream.write = make_encoded_write(self.gitStream.write) |
| 4035 | |
| 4036 | def closeStreams(self): |
| 4037 | if self.gitStream is None: |
| 4038 | return |
| 4039 | self.gitStream.close() |
| 4040 | if self.importProcess.wait() != 0: |
| 4041 | die("fast-import failed: %s" % self.gitError.read()) |
| 4042 | self.gitOutput.close() |
| 4043 | self.gitError.close() |
| 4044 | self.gitStream = None |
| 4045 | |
| 4046 | def run(self, args): |
| 4047 | if self.importIntoRemotes: |