| Alphare |
| hg-reviewers |
This mode would only be active on Python 2, which is no longer supported.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/windows.py (13 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| 69f0dae8d78e | a6c959594a95 | Gregory Szorc | Feb 21 2022, 12:38 PM |
| When writing to a broken pipe, EINVAL instead of EPIPE may be raised. | When writing to a broken pipe, EINVAL instead of EPIPE may be raised. | ||||
| When writing too many bytes to a console at the same, a "Not enough space" | When writing too many bytes to a console at the same, a "Not enough space" | ||||
| error may happen. Python 3 already works around that. | error may happen. Python 3 already works around that. | ||||
| """ | """ | ||||
| def __init__(self, fp): | def __init__(self, fp): | ||||
| self.fp = fp | self.fp = fp | ||||
| self.throttle = not pycompat.ispy3 and _isatty(fp) | |||||
| def __getattr__(self, key): | def __getattr__(self, key): | ||||
| return getattr(self.fp, key) | return getattr(self.fp, key) | ||||
| def close(self): | def close(self): | ||||
| try: | try: | ||||
| self.fp.close() | self.fp.close() | ||||
| except IOError: | except IOError: | ||||
| pass | pass | ||||
| def write(self, s): | def write(self, s): | ||||
| try: | try: | ||||
| if not self.throttle: | |||||
| return self.fp.write(s) | return self.fp.write(s) | ||||
| # This is workaround for "Not enough space" error on | |||||
| # writing large size of data to console. | |||||
| limit = 16000 | |||||
| l = len(s) | |||||
| start = 0 | |||||
| while start < l: | |||||
| end = start + limit | |||||
| self.fp.write(s[start:end]) | |||||
| start = end | |||||
| except IOError as inst: | except IOError as inst: | ||||
| if inst.errno != 0 and not win32.lasterrorwaspipeerror(inst): | if inst.errno != 0 and not win32.lasterrorwaspipeerror(inst): | ||||
| raise | raise | ||||
| self.close() | self.close() | ||||
| raise IOError(errno.EPIPE, 'Broken pipe') | raise IOError(errno.EPIPE, 'Broken pipe') | ||||
| def flush(self): | def flush(self): | ||||
| try: | try: | ||||