This is an archive of the discontinued Mercurial Phabricator instance.

Differential D2571

sshpeer: don't read from stderr when that behavior is disabled
ClosedPublic

Authored by indygreg on Mar 2 2018, 6:55 PM.

Details

Reviewers
durin42
Group Reviewers
hg-reviewers
Commits
rHG1151c731686e: sshpeer: don't read from stderr when that behavior is disabled
Summary

We previously prevented the creation of doublepipe instances when
we're not supposed to automatically read from stderr. However,
there were other automatic calls to read from stderr that were
undermining this effort.

This commit prevents all automatic reads from stderr from occurring
when they are supposed to be disabled.

Because stderr is no longer being read, we need to call "readavailable"
from tests so stderr is read from.

Test output changes because stderr is now always (manually) read after
stdout. And, since sshpeer no longer automatically tends to stderr,
no "remote: " messages are printed. This should fix non-deterministic
test output.

FWIW, doublepipe automatically reads from stderr when reading from
stdout, so I'm not sure some of these calls to self._readerr() are
even needed.

Diff Detail

Repository
rHG Mercurial
Lint
Automatic diff as part of commit; lint not applicable.
Unit
Automatic diff as part of commit; unit tests not applicable.

Event Timeline

indygreg created this revision.Mar 2 2018, 6:55 PM
durin42 accepted this revision.Mar 2 2018, 7:00 PM
This revision is now accepted and ready to land.Mar 2 2018, 7:00 PM
Closed by commit rHG1151c731686e: sshpeer: don't read from stderr when that behavior is disabled (authored by indygreg). · Explain WhyMar 2 2018, 7:13 PM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mmercurial/sshpeer.py (10 lines)
Mtests/test-ssh-proto-unbundle.t (437 lines)

Diff 6407

mercurial/sshpeer.py

if autoreadstderr: if autoreadstderr:
stdout = doublepipe(ui, util.bufferedinputpipe(stdout), stderr) stdout = doublepipe(ui, util.bufferedinputpipe(stdout), stderr)
stdin = doublepipe(ui, stdin, stderr) stdin = doublepipe(ui, stdin, stderr)
self._pipeo = stdin self._pipeo = stdin
self._pipei = stdout self._pipei = stdout
self._pipee = stderr self._pipee = stderr
self._caps = caps self._caps = caps
self._autoreadstderr = autoreadstderr
# Commands that have a "framed" response where the first line of the # Commands that have a "framed" response where the first line of the
# response contains the length of that response. # response contains the length of that response.
_FRAMED_COMMANDS = { _FRAMED_COMMANDS = {
'batch', 'batch',
} }
# Begin of _basepeer interface. # Begin of _basepeer interface.
self._writeframed(d) self._writeframed(d)
self._writeframed("", flush=True) self._writeframed("", flush=True)
return self._pipei return self._pipei
def _getamount(self): def _getamount(self):
l = self._pipei.readline() l = self._pipei.readline()
if l == '\n': if l == '\n':
if self._autoreadstderr:
self._readerr() self._readerr()
msg = _('check previous remote output') msg = _('check previous remote output')
self._abort(error.OutOfBandError(hint=msg)) self._abort(error.OutOfBandError(hint=msg))
if self._autoreadstderr:
self._readerr() self._readerr()
try: try:
return int(l) return int(l)
except ValueError: except ValueError:
self._abort(error.ResponseError(_("unexpected response:"), l)) self._abort(error.ResponseError(_("unexpected response:"), l))
def _readframed(self): def _readframed(self):
return self._pipei.read(self._getamount()) return self._pipei.read(self._getamount())
def _writeframed(self, data, flush=False): def _writeframed(self, data, flush=False):
self._pipeo.write("%d\n" % len(data)) self._pipeo.write("%d\n" % len(data))
if data: if data:
self._pipeo.write(data) self._pipeo.write(data)
if flush: if flush:
self._pipeo.flush() self._pipeo.flush()
if self._autoreadstderr:
self._readerr() self._readerr()
class sshv2peer(sshv1peer): class sshv2peer(sshv1peer):
"""A peer that speakers version 2 of the transport protocol.""" """A peer that speakers version 2 of the transport protocol."""
# Currently version 2 is identical to version 1 post handshake. # Currently version 2 is identical to version 1 post handshake.
# And handshake is performed before the peer is instantiated. So # And handshake is performed before the peer is instantiated. So
# we need no custom code. # we need no custom code.
def makepeer(ui, path, proc, stdin, stdout, stderr, autoreadstderr=True): def makepeer(ui, path, proc, stdin, stdout, stderr, autoreadstderr=True):

tests/test-ssh-proto-unbundle.t

> bundle1 = false > bundle1 = false
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
e> read(-1) -> 115:
e> abort: incompatible Mercurial client; bundle2 required\n
e> (see https://www.mercurial-scm.org/wiki/IncompatibleClient)\n
remote: abort: incompatible Mercurial client; bundle2 required
remote: (see https://www.mercurial-scm.org/wiki/IncompatibleClient)
o> read(0) -> 0: o> read(0) -> 0:
o> readline() -> 2: o> readline() -> 2:
o> 1\n o> 1\n
o> read(1) -> 1: 0 o> read(1) -> 1: 0
result: 0 result: 0
remote output: remote output:
e> read(-1) -> 115:
e> abort: incompatible Mercurial client; bundle2 required\n
e> (see https://www.mercurial-scm.org/wiki/IncompatibleClient)\n
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
e> read(-1) -> 115:
e> abort: incompatible Mercurial client; bundle2 required\n
e> (see https://www.mercurial-scm.org/wiki/IncompatibleClient)\n
remote: abort: incompatible Mercurial client; bundle2 required
remote: (see https://www.mercurial-scm.org/wiki/IncompatibleClient)
o> read(0) -> 0: o> read(0) -> 0:
o> readline() -> 2: o> readline() -> 2:
o> 1\n o> 1\n
o> read(1) -> 1: 0 o> read(1) -> 1: 0
result: 0 result: 0
remote output: remote output:
e> read(-1) -> 115:
e> abort: incompatible Mercurial client; bundle2 required\n
e> (see https://www.mercurial-scm.org/wiki/IncompatibleClient)\n
$ cd .. $ cd ..
Create a pretxnchangegroup hook that fails. Give it multiple modes of printing Create a pretxnchangegroup hook that fails. Give it multiple modes of printing
output so we can test I/O capture and behavior. output so we can test I/O capture and behavior.
Test pushing to a server that has a pretxnchangegroup Python hook that fails Test pushing to a server that has a pretxnchangegroup Python hook that fails
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hook1line > pretxnchangegroup.fail = python:$TESTTMP/failhook:hook1line
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 196: e> read(-1) -> 196:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1 line\n e> ui.write 1 line\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1 line
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 196: e> read(-1) -> 196:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1 line\n e> ui.write 1 line\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1 line
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
And a variation that writes multiple lines using ui.write And a variation that writes multiple lines using ui.write
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hook2lines > pretxnchangegroup.fail = python:$TESTTMP/failhook:hook2lines
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 218: e> read(-1) -> 218:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 2 lines 1\n e> ui.write 2 lines 1\n
e> ui.write 2 lines 2\n e> ui.write 2 lines 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 2 lines 1
remote: ui.write 2 lines 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 218: e> read(-1) -> 218:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 2 lines 1\n e> ui.write 2 lines 1\n
e> ui.write 2 lines 2\n e> ui.write 2 lines 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 2 lines 1
remote: ui.write 2 lines 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
And a variation that does a ui.flush() after writing output And a variation that does a ui.flush() after writing output
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hook1lineflush > pretxnchangegroup.fail = python:$TESTTMP/failhook:hook1lineflush
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 202: e> read(-1) -> 202:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1 line flush\n e> ui.write 1 line flush\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1 line flush
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 202: e> read(-1) -> 202:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1 line flush\n e> ui.write 1 line flush\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1 line flush
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
Multiple writes + flush Multiple writes + flush
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hookmultiflush > pretxnchangegroup.fail = python:$TESTTMP/failhook:hookmultiflush
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 206: e> read(-1) -> 206:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1st\n e> ui.write 1st\n
e> ui.write 2nd\n e> ui.write 2nd\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1st
remote: ui.write 2nd
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 206: e> read(-1) -> 206:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1st\n e> ui.write 1st\n
e> ui.write 2nd\n e> ui.write 2nd\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1st
remote: ui.write 2nd
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
ui.write() + ui.write_err() output is captured ui.write() + ui.write_err() output is captured
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hookwriteandwriteerr > pretxnchangegroup.fail = python:$TESTTMP/failhook:hookwriteandwriteerr
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 232: e> read(-1) -> 232:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write_err 1\n e> ui.write_err 1\n
e> ui.write 2\n e> ui.write 2\n
e> ui.write_err 2\n e> ui.write_err 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write_err 1
remote: ui.write 2
remote: ui.write_err 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 232: e> read(-1) -> 232:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write_err 1\n e> ui.write_err 1\n
e> ui.write 2\n e> ui.write 2\n
e> ui.write_err 2\n e> ui.write_err 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write_err 1
remote: ui.write 2
remote: ui.write_err 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
print() output is captured print() output is captured
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintstdout > pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintstdout
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 193: e> read(-1) -> 193:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> printed line\n e> printed line\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: printed line
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 193: e> read(-1) -> 193:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> printed line\n e> printed line\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: printed line
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
Mixed print() and ui.write() are both captured Mixed print() and ui.write() are both captured
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintandwrite > pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintandwrite
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 218: e> read(-1) -> 218:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write 2\n e> ui.write 2\n
e> print 1\n e> print 1\n
e> print 2\n e> print 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write 2
remote: print 1
remote: print 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 218: e> read(-1) -> 218:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write 2\n e> ui.write 2\n
e> print 1\n e> print 1\n
e> print 2\n e> print 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write 2
remote: print 1
remote: print 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
print() to stdout and stderr both get captured print() to stdout and stderr both get captured
$ cat > .hg/hgrc << EOF $ cat > .hg/hgrc << EOF
> [hooks] > [hooks]
> pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintstderrandstdout > pretxnchangegroup.fail = python:$TESTTMP/failhook:hookprintstderrandstdout
> EOF > EOF
$ debugwireproto << EOF $ debugwireproto << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 216: e> read(-1) -> 216:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> stderr 1\n e> stderr 1\n
e> stderr 2\n e> stderr 2\n
e> stdout 1\n e> stdout 1\n
e> stdout 2\n e> stdout 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: stderr 1
remote: stderr 2
remote: stdout 1
remote: stdout 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
e> read(-1) -> 216: e> read(-1) -> 216:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> stderr 1\n e> stderr 1\n
e> stderr 2\n e> stderr 2\n
e> stdout 1\n e> stdout 1\n
e> stdout 2\n e> stdout 2\n
e> transaction abort!\n e> transaction abort!\n
e> rollback completed\n e> rollback completed\n
e> abort: pretxnchangegroup.fail hook failed\n e> abort: pretxnchangegroup.fail hook failed\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: stderr 1
remote: stderr 2
remote: stdout 1
remote: stdout 2
remote: transaction abort!
remote: rollback completed
remote: abort: pretxnchangegroup.fail hook failed
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 0
result: 0
remote output:
$ cd .. $ cd ..
Pushing a bundle1 with no output Pushing a bundle1 with no output
$ hg init simplerepo $ hg init simplerepo
$ cd simplerepo $ cd simplerepo
$ debugwireproto 1 << EOF $ debugwireproto 1 << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
e> read(-1) -> 100:
e> adding changesets\n
e> adding manifests\n
e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
o> read(0) -> 0: o> read(0) -> 0:
o> readline() -> 2: o> readline() -> 2:
o> 1\n o> 1\n
o> read(1) -> 1: 1 o> read(1) -> 1: 1
result: 1 result: 1
remote output: remote output:
e> read(-1) -> 100:
e> adding changesets\n
e> adding manifests\n
e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
e> read(-1) -> 100:
e> adding changesets\n
e> adding manifests\n
e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
o> read(0) -> 0: o> read(0) -> 0:
o> readline() -> 2: o> readline() -> 2:
o> 1\n o> 1\n
o> read(1) -> 1: 1 o> read(1) -> 1: 1
result: 1 result: 1
remote output: remote output:
e> read(-1) -> 100:
e> adding changesets\n
e> adding manifests\n
e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n
$ cd .. $ cd ..
Pushing a bundle1 with ui.write() and ui.write_err() Pushing a bundle1 with ui.write() and ui.write_err()
$ cat > $TESTTMP/hook << EOF $ cat > $TESTTMP/hook << EOF
> def hookuiwrite(ui, repo, **kwargs): > def hookuiwrite(ui, repo, **kwargs):
> ui.write('ui.write 1\n') > ui.write('ui.write 1\n')
> pretxnchangegroup.hook = python:$TESTTMP/hook:hookuiwrite > pretxnchangegroup.hook = python:$TESTTMP/hook:hookuiwrite
> EOF > EOF
$ debugwireproto 1 << EOF $ debugwireproto 1 << EOF
> command unbundle > command unbundle
> # This is "force" in hex. > # This is "force" in hex.
> heads 666f726365 > heads 666f726365
> PUSHFILE ../initial.v1.hg > PUSHFILE ../initial.v1.hg
> readavailable
> EOF > EOF
testing ssh1 testing ssh1
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(104) -> None: i> write(104) -> None:
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000 i> 0000000000000000000000000000000000000000-0000000000000000000000000000000000000000
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 1
result: 1
remote output:
e> read(-1) -> 152: e> read(-1) -> 152:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write_err 1\n e> ui.write_err 1\n
e> ui.write 2\n e> ui.write 2\n
e> ui.write_err 2\n e> ui.write_err 2\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write_err 1
remote: ui.write 2
remote: ui.write_err 2
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 1
result: 1
remote output:
testing ssh2 testing ssh2
creating ssh peer from handshake results creating ssh peer from handshake results
i> write(171) -> None: i> write(171) -> None:
i> upgrade * proto=exp-ssh-v2-0001\n (glob) i> upgrade * proto=exp-ssh-v2-0001\n (glob)
i> hello\n i> hello\n
i> between\n i> between\n
i> pairs 81\n i> pairs 81\n
i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n i> initial\x00\x00\x00\x00\x00\x00\x00\x8d\xcb\xa4\x85\xca6x%n\x04D(\xf7\x0fX)\x11\x96\xf6\xe9\xde\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00362fef284ce2ca02aecc8de6d5e8a1c3af0556fe\n
i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n i> \x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00b6/\xef(L\xe2\xca\x02\xae\xcc\x8d\xe6\xd5\xe8\xa1\xc3\xaf\x05V\xfe\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00h\x98b\x13\xbdD\x85\xeaQS55\xe3\xfc\x9ex\x00zq\x1f\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x020\n
i> \x00\x00\x00\x00\x00\x00\x00\x00 i> \x00\x00\x00\x00\x00\x00\x00\x00
i> write(2) -> None: i> write(2) -> None:
i> 0\n i> 0\n
i> flush() -> None i> flush() -> None
o> readline() -> 2: o> readline() -> 2:
o> 0\n o> 0\n
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 1
result: 1
remote output:
e> read(-1) -> 152: e> read(-1) -> 152:
e> adding changesets\n e> adding changesets\n
e> adding manifests\n e> adding manifests\n
e> adding file changes\n e> adding file changes\n
e> added 1 changesets with 1 changes to 1 files\n e> added 1 changesets with 1 changes to 1 files\n
e> ui.write 1\n e> ui.write 1\n
e> ui.write_err 1\n e> ui.write_err 1\n
e> ui.write 2\n e> ui.write 2\n
e> ui.write_err 2\n e> ui.write_err 2\n
remote: adding changesets
remote: adding manifests
remote: adding file changes
remote: added 1 changesets with 1 changes to 1 files
remote: ui.write 1
remote: ui.write_err 1
remote: ui.write 2
remote: ui.write_err 2
o> read(0) -> 0:
o> readline() -> 2:
o> 1\n
o> read(1) -> 1: 1
result: 1
remote output: