comparison mercurial/utils/procutil.py @ 48487:333a2656e981

pytype: stop excluding procutil.py

This avoids these false warnings:

  File "/mnt/c/Users/Matt/hg/mercurial/utils/procutil.py", line 78, in <module>:
      No attribute 'register' on Type[io.BufferedIOBase] [attribute-error]
  File "/mnt/c/Users/Matt/hg/mercurial/utils/procutil.py", line 117, in <module>:
      No attribute 'register' on Type[io.IOBase] [attribute-error]
  File "/mnt/c/Users/Matt/hg/mercurial/utils/procutil.py", line 770, in runbgcommandpy3:
      No attribute 'close' on int [attribute-error]
    In Union[IO[Union[bytes, str]], int]

Differential Revision: https://phab.mercurial-scm.org/D11927

48486:7caaefa48794

        if s.endswith(b'\n'):
            orig.flush()
        return res


io.BufferedIOBase.register(LineBufferedWrapper)


def make_line_buffered(stream):
    if pycompat.ispy3 and not isinstance(stream, io.BufferedIOBase):
        # On Python 3, buffered streams can be expected to subclass

        while total_written < total_to_write:
            total_written += write1(m[total_written:])
        return total_written


io.IOBase.register(WriteAllWrapper)


def _make_write_all(stream):
    assert pycompat.ispy3
    if isinstance(stream, WriteAllWrapper):

            if record_wait is not None:
                record_wait(255)
            raise
        finally:
            if stdin_bytes is not None:
                stdin.close()
        if not ensurestart:
            # Even though we're not waiting on the child process,
            # we still must call waitpid() on it at some point so
            # it's not a zombie/defunct. This is especially relevant for

48487:333a2656e981

        if s.endswith(b'\n'):
            orig.flush()
        return res


# pytype: disable=attribute-error
io.BufferedIOBase.register(LineBufferedWrapper)
# pytype: enable=attribute-error


def make_line_buffered(stream):
    if pycompat.ispy3 and not isinstance(stream, io.BufferedIOBase):
        # On Python 3, buffered streams can be expected to subclass

        while total_written < total_to_write:
            total_written += write1(m[total_written:])
        return total_written


# pytype: disable=attribute-error
io.IOBase.register(WriteAllWrapper)
# pytype: enable=attribute-error


def _make_write_all(stream):
    assert pycompat.ispy3
    if isinstance(stream, WriteAllWrapper):

            if record_wait is not None:
                record_wait(255)
            raise
        finally:
            if stdin_bytes is not None:
                assert not isinstance(stdin, int)
                stdin.close()
        if not ensurestart:
            # Even though we're not waiting on the child process,
            # we still must call waitpid() on it at some point so
            # it's not a zombie/defunct. This is especially relevant for