equal
deleted
inserted
replaced
566 self._pipeo.flush() |
566 self._pipeo.flush() |
567 if self._autoreadstderr: |
567 if self._autoreadstderr: |
568 self._readerr() |
568 self._readerr() |
569 |
569 |
570 |
570 |
571 def makepeer(ui, path, proc, stdin, stdout, stderr, autoreadstderr=True): |
571 def _make_peer(ui, path, proc, stdin, stdout, stderr, autoreadstderr=True): |
572 """Make a peer instance from existing pipes. |
572 """Make a peer instance from existing pipes. |
573 |
573 |
574 ``path`` and ``proc`` are stored on the eventual peer instance and may |
574 ``path`` and ``proc`` are stored on the eventual peer instance and may |
575 not be used for anything meaningful. |
575 not be used for anything meaningful. |
576 |
576 |
656 |
656 |
657 proc, stdin, stdout, stderr = _makeconnection( |
657 proc, stdin, stdout, stderr = _makeconnection( |
658 ui, sshcmd, args, remotecmd, remotepath, sshenv |
658 ui, sshcmd, args, remotecmd, remotepath, sshenv |
659 ) |
659 ) |
660 |
660 |
661 peer = makepeer(ui, path, proc, stdin, stdout, stderr) |
661 peer = _make_peer(ui, path, proc, stdin, stdout, stderr) |
662 |
662 |
663 # Finally, if supported by the server, notify it about our own |
663 # Finally, if supported by the server, notify it about our own |
664 # capabilities. |
664 # capabilities. |
665 if b'protocaps' in peer.capabilities(): |
665 if b'protocaps' in peer.capabilities(): |
666 try: |
666 try: |