equal
deleted
inserted
replaced
766 # opencode timeblockedsection because this is a critical path |
766 # opencode timeblockedsection because this is a critical path |
767 starttime = util.timer() |
767 starttime = util.timer() |
768 try: |
768 try: |
769 for a in msgs: |
769 for a in msgs: |
770 self.fout.write(a) |
770 self.fout.write(a) |
|
771 except IOError as err: |
|
772 raise error.StdioError(err) |
771 finally: |
773 finally: |
772 self._blockedtimes['stdio_blocked'] += \ |
774 self._blockedtimes['stdio_blocked'] += \ |
773 (util.timer() - starttime) * 1000 |
775 (util.timer() - starttime) * 1000 |
774 |
776 |
775 def write_err(self, *args, **opts): |
777 def write_err(self, *args, **opts): |