upstream/mercurial-mirror Commit - r32002:bf855efe

httppeer: wrap HTTPResponse.read() globally...

Gregory Szorc -

r32002:bf855efe default

parent child

mercurial/error.py

0 +3 0

              # error.py - Mercurial exceptions
              #
              # Copyright 2005-2008 Matt Mackall <mpm@selenic.com>
              #
              # This software may be used and distributed according to the terms of the
              # GNU General Public License version 2 or any later version.
              """Mercurial exceptions.
              This allows us to catch exceptions at higher levels without forcing
              imports.
              """
              from __future__ import absolute_import
              # Do not import anything here, please
              class Hint(object):
                  """Mix-in to provide a hint of an error
                  This should come first in the inheritance list to consume a hint and
                  pass remaining arguments to the exception class.
                  """
                  def __init__(self, *args, **kw):
                      self.hint = kw.pop(r'hint', None)
                      super(Hint, self).__init__(*args, **kw)
              class RevlogError(Hint, Exception):
                  pass
              class FilteredIndexError(IndexError):
                  pass
              class LookupError(RevlogError, KeyError):
                  def __init__(self, name, index, message):
                      self.name = name
                      self.index = index
                      # this can't be called 'message' because at least some installs of
                      # Python 2.6+ complain about the 'message' property being deprecated
                      self.lookupmessage = message
                      if isinstance(name, str) and len(name) == 20:
                          from .node import short
                          name = short(name)
                      RevlogError.__init__(self, '%s@%s: %s' % (index, name, message))
                  def __str__(self):
                      return RevlogError.__str__(self)
              class FilteredLookupError(LookupError):
                  pass
              class ManifestLookupError(LookupError):
                  pass
              class CommandError(Exception):
                  """Exception raised on errors in parsing the command line."""
              class InterventionRequired(Hint, Exception):
                  """Exception raised when a command requires human intervention."""
              class Abort(Hint, Exception):
                  """Raised if a command needs to print an error and exit."""
              class HookLoadError(Abort):
                  """raised when loading a hook fails, aborting an operation
                  Exists to allow more specialized catching."""
              class HookAbort(Abort):
                  """raised when a validation hook fails, aborting an operation
                  Exists to allow more specialized catching."""
              class ConfigError(Abort):
                  """Exception raised when parsing config files"""
              class UpdateAbort(Abort):
                  """Raised when an update is aborted for destination issue"""
              class MergeDestAbort(Abort):
                  """Raised when an update is aborted for destination issues"""
              class NoMergeDestAbort(MergeDestAbort):
                  """Raised when an update is aborted because there is nothing to merge"""
              class ManyMergeDestAbort(MergeDestAbort):
                  """Raised when an update is aborted because destination is ambiguous"""
              class ResponseExpected(Abort):
                  """Raised when an EOF is received for a prompt"""
                  def __init__(self):
                      from .i18n import _
                      Abort.__init__(self, _('response expected'))
              class OutOfBandError(Hint, Exception):
                  """Exception raised when a remote repo reports failure"""
              class ParseError(Hint, Exception):
                  """Raised when parsing config files and {rev,file}sets (msg[, pos])"""
              class UnknownIdentifier(ParseError):
                  """Exception raised when a {rev,file}set references an unknown identifier"""
                  def __init__(self, function, symbols):
                      from .i18n import _
                      ParseError.__init__(self, _("unknown identifier: %s") % function)
                      self.function = function
                      self.symbols = symbols
              class RepoError(Hint, Exception):
                  pass
              class RepoLookupError(RepoError):
                  pass
              class FilteredRepoLookupError(RepoLookupError):
                  pass
              class CapabilityError(RepoError):
                  pass
              class RequirementError(RepoError):
                  """Exception raised if .hg/requires has an unknown entry."""
              class StdioError(IOError):
                  """Raised if I/O to stdout or stderr fails"""
                  def __init__(self, err):
                      IOError.__init__(self, err.errno, err.strerror)
              class UnsupportedMergeRecords(Abort):
                  def __init__(self, recordtypes):
                      from .i18n import _
                      self.recordtypes = sorted(recordtypes)
                      s = ' '.join(self.recordtypes)
                      Abort.__init__(
                          self, _('unsupported merge state records: %s') % s,
                          hint=_('see https://mercurial-scm.org/wiki/MergeStateRecords for '
                                 'more information'))
              class LockError(IOError):
                  def __init__(self, errno, strerror, filename, desc):
                      IOError.__init__(self, errno, strerror, filename)
                      self.desc = desc
              class LockHeld(LockError):
                  def __init__(self, errno, filename, desc, locker):
                      LockError.__init__(self, errno, 'Lock held', filename, desc)
                      self.locker = locker
              class LockUnavailable(LockError):
                  pass
              # LockError is for errors while acquiring the lock -- this is unrelated
              class LockInheritanceContractViolation(RuntimeError):
                  pass
              class ResponseError(Exception):
                  """Raised to print an error with part of output and exit."""
              class UnknownCommand(Exception):
                  """Exception raised if command is not in the command table."""
              class AmbiguousCommand(Exception):
                  """Exception raised if command shortcut matches more than one command."""
              # derived from KeyboardInterrupt to simplify some breakout code
              class SignalInterrupt(KeyboardInterrupt):
                  """Exception raised on SIGTERM and SIGHUP."""
              class SignatureError(Exception):
                  pass
              class PushRaced(RuntimeError):
                  """An exception raised during unbundling that indicate a push race"""
              class ProgrammingError(RuntimeError):
                  """Raised if a mercurial (core or extension) developer made a mistake"""
              # bundle2 related errors
              class BundleValueError(ValueError):
                  """error raised when bundle2 cannot be processed"""
              class BundleUnknownFeatureError(BundleValueError):
                  def __init__(self, parttype=None, params=(), values=()):
                      self.parttype = parttype
                      self.params = params
                      self.values = values
                      if self.parttype is None:
                          msg = 'Stream Parameter'
                      else:
                          msg = parttype
                      entries = self.params
                      if self.params and self.values:
                          assert len(self.params) == len(self.values)
                          entries = []
                          for idx, par in enumerate(self.params):
                              val = self.values[idx]
                              if val is None:
                                  entries.append(val)
                              else:
                                  entries.append("%s=%r" % (par, val))
                      if entries:
                          msg = '%s - %s' % (msg, ', '.join(entries))
                      ValueError.__init__(self, msg)
              class ReadOnlyPartError(RuntimeError):
                  """error raised when code tries to alter a part being generated"""
              class PushkeyFailed(Abort):
                  """error raised when a pushkey part failed to update a value"""
                  def __init__(self, partid, namespace=None, key=None, new=None, old=None,
                               ret=None):
                      self.partid = partid
                      self.namespace = namespace
                      self.key = key
                      self.new = new
                      self.old = old
                      self.ret = ret
                      # no i18n expected to be processed into a better message
                      Abort.__init__(self, 'failed to update value for "%s/%s"'
                                     % (namespace, key))
              class CensoredNodeError(RevlogError):
                  """error raised when content verification fails on a censored node
                  Also contains the tombstone data substituted for the uncensored data.
                  """
                  def __init__(self, filename, node, tombstone):
                      from .node import short
                      RevlogError.__init__(self, '%s:%s' % (filename, short(node)))
                      self.tombstone = tombstone
              class CensoredBaseError(RevlogError):
                  """error raised when a delta is rejected because its base is censored
                  A delta based on a censored revision must be formed as single patch
                  operation which replaces the entire base with new content. This ensures
                  the delta may be applied by clones which have not censored the base.
                  """
              class InvalidBundleSpecification(Exception):
                  """error raised when a bundle specification is invalid.
                  This is used for syntax errors as opposed to support errors.
                  """
              class UnsupportedBundleSpecification(Exception):
                  """error raised when a bundle specification is not supported."""
              class CorruptedState(Exception):
                  """error raised when a command is not able to read its state from file"""
+             class RichIOError(Abort):
+                 """An IOError that can also have a hint attached."""

mercurial/httppeer.py

0 +39 0

              # httppeer.py - HTTP repository proxy classes for mercurial
              #
              # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
              # Copyright 2006 Vadim Gelfer <vadim.gelfer@gmail.com>
              #
              # This software may be used and distributed according to the terms of the
              # GNU General Public License version 2 or any later version.
              from __future__ import absolute_import
              import errno
              import os
              import socket
              import struct
              import tempfile
              from .i18n import _
              from .node import nullid
              from . import (
                  bundle2,
                  error,
                  httpconnection,
                  pycompat,
                  statichttprepo,
                  url,
                  util,
                  wireproto,
              )
              httplib = util.httplib
              urlerr = util.urlerr
              urlreq = util.urlreq
              # FUTURE: consider refactoring this API to use generators. This will
              # require a compression engine API to emit generators.
              def decompressresponse(response, engine):
                  try:
                      reader = engine.decompressorreader(response)
                  except httplib.HTTPException:
                      raise IOError(None, _('connection ended unexpectedly'))
                  # We need to wrap reader.read() so HTTPException on subsequent
                  # reads is also converted.
                  # Ideally we'd use super() here. However, if ``reader`` isn't a new-style
                  # class, this can raise:
                  # TypeError: super() argument 1 must be type, not classobj
                  origread = reader.read
                  class readerproxy(reader.__class__):
                      def read(self, *args, **kwargs):
                          try:
                              return origread(*args, **kwargs)
                          except httplib.HTTPException:
                              raise IOError(None, _('connection ended unexpectedly'))
                  reader.__class__ = readerproxy
                  return reader
              def encodevalueinheaders(value, header, limit):
                  """Encode a string value into multiple HTTP headers.
                  ``value`` will be encoded into 1 or more HTTP headers with the names
                  ``header-<N>`` where ``<N>`` is an integer starting at 1. Each header
                  name + value will be at most ``limit`` bytes long.
                  Returns an iterable of 2-tuples consisting of header names and values.
                  """
                  fmt = header + '-%s'
                  valuelen = limit - len(fmt % '000') - len(': \r\n')
                  result = []
                  n = 0
                  for i in xrange(0, len(value), valuelen):
                      n += 1
                      result.append((fmt % str(n), value[i:i + valuelen]))
                  return result
+             def _wraphttpresponse(resp):
+                 """Wrap an HTTPResponse with common error handlers.
+                 This ensures that any I/O from any consumer raises the appropriate
+                 error and messaging.
+                 """
+                 origread = resp.read
+                 class readerproxy(resp.__class__):
+                     def read(self, size=None):
+                         try:
+                             return origread(size)
+                         except httplib.IncompleteRead as e:
+                             # e.expected is an integer if length known or None otherwise.
+                             if e.expected:
+                                 msg = _('HTTP request error (incomplete response; '
+                                         'expected %d bytes got %d)') % (e.expected,
+                                                                        len(e.partial))
+                             else:
+                                 msg = _('HTTP request error (incomplete response)')
+                             raise error.RichIOError(
+                                 msg,
+                                 hint=_('this may be an intermittent network failure; '
+                                        'if the error persists, consider contacting the '
+                                        'network or server operator'))
+                         except httplib.HTTPException as e:
+                             raise error.RichIOError(
+                                 _('HTTP request error (%s)') % e,
+                                 hint=_('this may be an intermittent failure; '
+                                        'if the error persists, consider contacting the '
+                                        'network or server operator'))
+                 resp.__class__ = readerproxy
              class httppeer(wireproto.wirepeer):
                  def __init__(self, ui, path):
                      self.path = path
                      self.caps = None
                      self.handler = None
                      self.urlopener = None
                      self.requestbuilder = None
                      u = util.url(path)
                      if u.query or u.fragment:
                          raise error.Abort(_('unsupported URL component: "%s"') %
                                           (u.query or u.fragment))
                      # urllib cannot handle URLs with embedded user or passwd
                      self._url, authinfo = u.authinfo()
                      self.ui = ui
                      self.ui.debug('using %s\n' % self._url)
                      self.urlopener = url.opener(ui, authinfo)
                      self.requestbuilder = urlreq.request
                  def __del__(self):
                      urlopener = getattr(self, 'urlopener', None)
                      if urlopener:
                          for h in urlopener.handlers:
                              h.close()
                              getattr(h, "close_all", lambda : None)()
                  def url(self):
                      return self.path
                  # look up capabilities only when needed
                  def _fetchcaps(self):
                      self.caps = set(self._call('capabilities').split())
                  def _capabilities(self):
                      if self.caps is None:
                          try:
                              self._fetchcaps()
                          except error.RepoError:
                              self.caps = set()
                          self.ui.debug('capabilities: %s\n' %
                                        (' '.join(self.caps or ['none'])))
                      return self.caps
                  def lock(self):
                      raise error.Abort(_('operation not supported over http'))
                  def _callstream(self, cmd, _compressible=False, **args):
                      if cmd == 'pushkey':
                          args['data'] = ''
                      data = args.pop('data', None)
                      headers = args.pop('headers', {})
                      self.ui.debug("sending %s command\n" % cmd)
                      q = [('cmd', cmd)]
                      headersize = 0
                      varyheaders = []
                      # Important: don't use self.capable() here or else you end up
                      # with infinite recursion when trying to look up capabilities
                      # for the first time.
                      postargsok = self.caps is not None and 'httppostargs' in self.caps
                      # TODO: support for httppostargs when data is a file-like
                      # object rather than a basestring
                      canmungedata = not data or isinstance(data, basestring)
                      if postargsok and canmungedata:
                          strargs = urlreq.urlencode(sorted(args.items()))
                          if strargs:
                              if not data:
                                  data = strargs
                              elif isinstance(data, basestring):
                                  data = strargs + data
                              headers['X-HgArgs-Post'] = len(strargs)
                      else:
                          if len(args) > 0:
                              httpheader = self.capable('httpheader')
                              if httpheader:
                                  headersize = int(httpheader.split(',', 1)[0])
                          if headersize > 0:
                              # The headers can typically carry more data than the URL.
                              encargs = urlreq.urlencode(sorted(args.items()))
                              for header, value in encodevalueinheaders(encargs, 'X-HgArg',
                                                                        headersize):
                                  headers[header] = value
                                  varyheaders.append(header)
                          else:
                              q += sorted(args.items())
                      qs = '?%s' % urlreq.urlencode(q)
                      cu = "%s%s" % (self._url, qs)
                      size = 0
                      if util.safehasattr(data, 'length'):
                          size = data.length
                      elif data is not None:
                          size = len(data)
                      if size and self.ui.configbool('ui', 'usehttp2', False):
                          headers['Expect'] = '100-Continue'
                          headers['X-HgHttp2'] = '1'
                      if data is not None and 'Content-Type' not in headers:
                          headers['Content-Type'] = 'application/mercurial-0.1'
                      # Tell the server we accept application/mercurial-0.2 and multiple
                      # compression formats if the server is capable of emitting those
                      # payloads.
                      protoparams = []
                      mediatypes = set()
                      if self.caps is not None:
                          mt = self.capable('httpmediatype')
                          if mt:
                              protoparams.append('0.1')
                              mediatypes = set(mt.split(','))
                      if '0.2tx' in mediatypes:
                          protoparams.append('0.2')
                      if '0.2tx' in mediatypes and self.capable('compression'):
                          # We /could/ compare supported compression formats and prune
                          # non-mutually supported or error if nothing is mutually supported.
                          # For now, send the full list to the server and have it error.
                          comps = [e.wireprotosupport().name for e in
                                   util.compengines.supportedwireengines(util.CLIENTROLE)]
                          protoparams.append('comp=%s' % ','.join(comps))
                      if protoparams:
                          protoheaders = encodevalueinheaders(' '.join(protoparams),
                                                              'X-HgProto',
                                                              headersize or 1024)
                          for header, value in protoheaders:
                              headers[header] = value
                              varyheaders.append(header)
                      headers['Vary'] = ','.join(varyheaders)
                      req = self.requestbuilder(cu, data, headers)
                      if data is not None:
                          self.ui.debug("sending %s bytes\n" % size)
                          req.add_unredirected_header('Content-Length', '%d' % size)
                      try:
                          resp = self.urlopener.open(req)
                      except urlerr.httperror as inst:
                          if inst.code == 401:
                              raise error.Abort(_('authorization failed'))
                          raise
                      except httplib.HTTPException as inst:
                          self.ui.debug('http error while sending %s command\n' % cmd)
                          self.ui.traceback()
                          raise IOError(None, inst)
+                     # Insert error handlers for common I/O failures.
+                     _wraphttpresponse(resp)
                      # record the url we got redirected to
                      resp_url = resp.geturl()
                      if resp_url.endswith(qs):
                          resp_url = resp_url[:-len(qs)]
                      if self._url.rstrip('/') != resp_url.rstrip('/'):
                          if not self.ui.quiet:
                              self.ui.warn(_('real URL is %s\n') % resp_url)
                      self._url = resp_url
                      try:
                          proto = resp.getheader('content-type')
                      except AttributeError:
                          proto = resp.headers.get('content-type', '')
                      safeurl = util.hidepassword(self._url)
                      if proto.startswith('application/hg-error'):
                          raise error.OutOfBandError(resp.read())
                      # accept old "text/plain" and "application/hg-changegroup" for now
                      if not (proto.startswith('application/mercurial-') or
                              (proto.startswith('text/plain')
                               and not resp.headers.get('content-length')) or
                              proto.startswith('application/hg-changegroup')):
                          self.ui.debug("requested URL: '%s'\n" % util.hidepassword(cu))
                          raise error.RepoError(
                              _("'%s' does not appear to be an hg repository:\n"
                                "---%%<--- (%s)\n%s\n---%%<---\n")
                              % (safeurl, proto or 'no content-type', resp.read(1024)))
                      if proto.startswith('application/mercurial-'):
                          try:
                              version = proto.split('-', 1)[1]
                              version_info = tuple([int(n) for n in version.split('.')])
                          except ValueError:
                              raise error.RepoError(_("'%s' sent a broken Content-Type "
                                                      "header (%s)") % (safeurl, proto))
                          if version_info == (0, 1):
                              if _compressible:
                                  return decompressresponse(resp, util.compengines['zlib'])
                              return resp
                          elif version_info == (0, 2):
                              # application/mercurial-0.2 always identifies the compression
                              # engine in the payload header.
                              elen = struct.unpack('B', resp.read(1))[0]
                              ename = resp.read(elen)
                              engine = util.compengines.forwiretype(ename)
                              return decompressresponse(resp, engine)
                          else:
                              raise error.RepoError(_("'%s' uses newer protocol %s") %
                                                    (safeurl, version))
                      if _compressible:
                          return decompressresponse(resp, util.compengines['zlib'])
                      return resp
                  def _call(self, cmd, **args):
                      fp = self._callstream(cmd, **args)
                      try:
                          return fp.read()
                      finally:
                          # if using keepalive, allow connection to be reused
                          fp.close()
                  def _callpush(self, cmd, cg, **args):
                      # have to stream bundle to a temp file because we do not have
                      # http 1.1 chunked transfer.
                      types = self.capable('unbundle')
                      try:
                          types = types.split(',')
                      except AttributeError:
                          # servers older than d1b16a746db6 will send 'unbundle' as a
                          # boolean capability. They only support headerless/uncompressed
                          # bundles.
                          types = [""]
                      for x in types:
                          if x in bundle2.bundletypes:
                              type = x
                              break
                      tempname = bundle2.writebundle(self.ui, cg, None, type)
                      fp = httpconnection.httpsendfile(self.ui, tempname, "rb")
                      headers = {'Content-Type': 'application/mercurial-0.1'}
                      try:
                          r = self._call(cmd, data=fp, headers=headers, **args)
                          vals = r.split('\n', 1)
                          if len(vals) < 2:
                              raise error.ResponseError(_("unexpected response:"), r)
                          return vals
                      except socket.error as err:
                          if err.args[0] in (errno.ECONNRESET, errno.EPIPE):
                              raise error.Abort(_('push failed: %s') % err.args[1])
                          raise error.Abort(err.args[1])
                      finally:
                          fp.close()
                          os.unlink(tempname)
                  def _calltwowaystream(self, cmd, fp, **args):
                      fh = None
                      fp_ = None
                      filename = None
                      try:
                          # dump bundle to disk
                          fd, filename = tempfile.mkstemp(prefix="hg-bundle-", suffix=".hg")
                          fh = os.fdopen(fd, pycompat.sysstr("wb"))
                          d = fp.read(4096)
                          while d:
                              fh.write(d)
                              d = fp.read(4096)
                          fh.close()
                          # start http push
                          fp_ = httpconnection.httpsendfile(self.ui, filename, "rb")
                          headers = {'Content-Type': 'application/mercurial-0.1'}
                          return self._callstream(cmd, data=fp_, headers=headers, **args)
                      finally:
                          if fp_ is not None:
                              fp_.close()
                          if fh is not None:
                              fh.close()
                              os.unlink(filename)
                  def _callcompressable(self, cmd, **args):
                      return self._callstream(cmd, _compressible=True, **args)
                  def _abort(self, exception):
                      raise exception
              class httpspeer(httppeer):
                  def __init__(self, ui, path):
                      if not url.has_https:
                          raise error.Abort(_('Python support for SSL and HTTPS '
                                             'is not installed'))
                      httppeer.__init__(self, ui, path)
              def instance(ui, path, create):
                  if create:
                      raise error.Abort(_('cannot create new http repository'))
                  try:
                      if path.startswith('https:'):
                          inst = httpspeer(ui, path)
                      else:
                          inst = httppeer(ui, path)
                      try:
                          # Try to do useful work when checking compatibility.
                          # Usually saves a roundtrip since we want the caps anyway.
                          inst._fetchcaps()
                      except error.RepoError:
                          # No luck, try older compatibility check.
                          inst.between([(nullid, nullid)])
                      return inst
                  except error.RepoError as httpexception:
                      try:
                          r = statichttprepo.instance(ui, "static-" + path, create)
                          ui.note(_('(falling back to static-http)\n'))
                          return r
                      except error.RepoError:
                          raise httpexception # use the original http RepoError instead

tests/test-http-bad-server.t

0 +22 -17

              #require killdaemons serve zstd
              Client version is embedded in HTTP request and is effectively dynamic. Pin the
              version so behavior is deterministic.
                $ cat > fakeversion.py << EOF
                > from mercurial import util
                > util.version = lambda: '4.2'
                > EOF
                $ cat >> $HGRCPATH << EOF
                > [extensions]
                > fakeversion = `pwd`/fakeversion.py
                > EOF
                $ hg init server0
                $ cd server0
                $ touch foo
                $ hg -q commit -A -m initial
              Also disable compression because zstd is optional and causes output to vary
              and because debugging partial responses is hard when compression is involved
                $ cat > .hg/hgrc << EOF
                > [extensions]
                > badserver = $TESTDIR/badserverext.py
                > [server]
                > compressionengines = none
                > EOF
              Failure to accept() socket should result in connection related error message
                $ hg --config badserver.closebeforeaccept=true serve -p $HGPORT -d --pid-file=hg.pid
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: Connection reset by peer
                [255]
              (The server exits on its own, but there is a race between that and starting a new server.
              So ensure the process is dead.)
                $ killdaemons.py $DAEMON_PIDS
              Failure immediately after accept() should yield connection related error message
                $ hg --config badserver.closeafteraccept=true serve -p $HGPORT -d --pid-file=hg.pid
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: Connection reset by peer
                [255]
                $ killdaemons.py $DAEMON_PIDS
              Failure to read all bytes in initial HTTP request should yield connection related error message
                $ hg --config badserver.closeafterrecvbytes=1 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
              TODO this error message is not very good
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: ''
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(1 from 65537) -> (1) G
                read limit reached; closing socket
                $ rm -f error.log
              Same failure, but server reads full HTTP request line
                $ hg --config badserver.closeafterrecvbytes=40 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: ''
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(40 from 65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(7 from -1) -> (7) Accept-
                read limit reached; closing socket
                $ rm -f error.log
              Failure on subsequent HTTP request on the same socket (cmd?batch)
                $ hg --config badserver.closeafterrecvbytes=210 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: ''
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(210 from 65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(177 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(150 from -1) -> (8) vary: \r\n
                readline(142 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(107 from -1) -> (23) host: localhost:$HGPORT\r\n
                readline(84 from -1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(35 from -1) -> (2) \r\n
                write(36) -> HTTP/1.1 200 Script output follows\r\n
                write(23) -> Server: badhttpserver\r\n
                write(37) -> Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41) -> Content-Type: application/mercurial-0.1\r\n
                write(21) -> Content-Length: 405\r\n
                write(2) -> \r\n
                write(405) -> lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(33 from 65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(7 from -1) -> (7) Accept-
                read limit reached; closing socket
                readline(210 from 65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(184 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(157 from -1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(128 from -1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(87 from -1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(39 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(4 from -1) -> (4) host
                read limit reached; closing socket
                $ rm -f error.log
              Failure to read getbundle HTTP request
                $ hg --config badserver.closeafterrecvbytes=300 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                abort: error: ''
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(300 from 65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(267 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(240 from -1) -> (8) vary: \r\n
                readline(232 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(197 from -1) -> (23) host: localhost:$HGPORT\r\n
                readline(174 from -1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(125 from -1) -> (2) \r\n
                write(36) -> HTTP/1.1 200 Script output follows\r\n
                write(23) -> Server: badhttpserver\r\n
                write(37) -> Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41) -> Content-Type: application/mercurial-0.1\r\n
                write(21) -> Content-Length: 405\r\n
                write(2) -> \r\n
                write(405) -> lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(123 from 65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(97 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(70 from -1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(41 from -1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                read limit reached; closing socket
                readline(300 from 65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(274 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(247 from -1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(218 from -1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(177 from -1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(129 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(94 from -1) -> (23) host: localhost:$HGPORT\r\n
                readline(71 from -1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(22 from -1) -> (2) \r\n
                write(36) -> HTTP/1.1 200 Script output follows\r\n
                write(23) -> Server: badhttpserver\r\n
                write(37) -> Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41) -> Content-Type: application/mercurial-0.1\r\n
                write(20) -> Content-Length: 42\r\n
                write(2) -> \r\n
                write(42) -> 96ee1d7354c4ad7372047672c36a1f561e3a6a4c\n;
                readline(20 from 65537) -> (20) GET /?cmd=getbundle
                read limit reached; closing socket
                readline(300 from 65537) -> (30) GET /?cmd=getbundle HTTP/1.1\r\n
                readline(270 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(243 from -1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(214 from -1) -> (214) x-hgarg-1: bundlecaps=HG20%2Cbundle2%3DHG20%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%2
                read limit reached; closing socket
                $ rm -f error.log
              Now do a variation using POST to send arguments
                $ hg --config experimental.httppostargs=true --config badserver.closeafterrecvbytes=315 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: ''
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(315 from 65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(282 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(255 from -1) -> (8) vary: \r\n
                readline(247 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(212 from -1) -> (23) host: localhost:$HGPORT\r\n
                readline(189 from -1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(140 from -1) -> (2) \r\n
                write(36) -> HTTP/1.1 200 Script output follows\r\n
                write(23) -> Server: badhttpserver\r\n
                write(37) -> Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41) -> Content-Type: application/mercurial-0.1\r\n
                write(21) -> Content-Length: 418\r\n
                write(2) -> \r\n
                write(418) -> lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httppostargs httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(138 from 65537) -> (27) POST /?cmd=batch HTTP/1.1\r\n
                readline(111 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(84 from -1) -> (41) content-type: application/mercurial-0.1\r\n
                readline(43 from -1) -> (19) vary: X-HgProto-1\r\n
                readline(24 from -1) -> (19) x-hgargs-post: 28\r\n
                readline(5 from -1) -> (5) x-hgp
                read limit reached; closing socket
                readline(315 from 65537) -> (27) POST /?cmd=batch HTTP/1.1\r\n
                readline(288 from -1) -> (27) Accept-Encoding: identity\r\n
                readline(261 from -1) -> (41) content-type: application/mercurial-0.1\r\n
                readline(220 from -1) -> (19) vary: X-HgProto-1\r\n
                readline(201 from -1) -> (19) x-hgargs-post: 28\r\n
                readline(182 from -1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(134 from -1) -> (35) accept: application/mercurial-0.1\r\n
                readline(99 from -1) -> (20) content-length: 28\r\n
                readline(79 from -1) -> (23) host: localhost:$HGPORT\r\n
                readline(56 from -1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(7 from -1) -> (2) \r\n
                read(5 from 28) -> (5) cmds=
                read limit reached, closing socket
                write(36) -> HTTP/1.1 500 Internal Server Error\r\n
                $ rm -f error.log
              Now move on to partial server responses
              Server sends a single character from the HTTP response line
                $ hg --config badserver.closeaftersendbytes=1 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                abort: error: H
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(1 from 36) -> (0) H
                write limit reached; closing socket
                write(36) -> HTTP/1.1 500 Internal Server Error\r\n
                $ rm -f error.log
              Server sends an incomplete capabilities response body
                $ hg --config badserver.closeaftersendbytes=180 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
-             TODO client spews a stack due to uncaught httplib.IncompleteRead
-               $ hg clone http://localhost:$HGPORT/ clone 2> /dev/null
-               [1]
+               $ hg clone http://localhost:$HGPORT/ clone
+               abort: HTTP request error (incomplete response; expected 385 bytes got 20)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
+               [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (144) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (121) Server: badhttpserver\r\n
                write(37 from 37) -> (84) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (43) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (22) Content-Length: 405\r\n
                write(2 from 2) -> (20) \r\n
                write(20 from 405) -> (0) lookup changegroupsu
                write limit reached; closing socket
                $ rm -f error.log
              Server sends incomplete headers for batch request
                $ hg --config badserver.closeaftersendbytes=695 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
              TODO this output is horrible
                $ hg clone http://localhost:$HGPORT/ clone
                abort: 'http://localhost:$HGPORT/' does not appear to be an hg repository:
                ---%<--- (application/mercuria)
                ---%<---
                !
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (659) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (636) Server: badhttpserver\r\n
                write(37 from 37) -> (599) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (558) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (537) Content-Length: 405\r\n
                write(2 from 2) -> (535) \r\n
                write(405 from 405) -> (130) lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (94) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (71) Server: badhttpserver\r\n
                write(37 from 37) -> (34) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(34 from 41) -> (0) Content-Type: application/mercuria
                write limit reached; closing socket
                write(36) -> HTTP/1.1 500 Internal Server Error\r\n
                $ rm -f error.log
              Server sends an incomplete HTTP response body to batch request
                $ hg --config badserver.closeaftersendbytes=760 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
              TODO client spews a stack due to uncaught ValueError in batch.results()
                $ hg clone http://localhost:$HGPORT/ clone 2> /dev/null
                [1]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (724) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (701) Server: badhttpserver\r\n
                write(37 from 37) -> (664) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (623) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (602) Content-Length: 405\r\n
                write(2 from 2) -> (600) \r\n
                write(405 from 405) -> (195) lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (159) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (136) Server: badhttpserver\r\n
                write(37 from 37) -> (99) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (58) Content-Type: application/mercurial-0.1\r\n
                write(20 from 20) -> (38) Content-Length: 42\r\n
                write(2 from 2) -> (36) \r\n
                write(36 from 42) -> (0) 96ee1d7354c4ad7372047672c36a1f561e3a
                write limit reached; closing socket
                $ rm -f error.log
              Server sends incomplete headers for getbundle response
                $ hg --config badserver.closeaftersendbytes=895 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
              TODO this output is terrible
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                abort: 'http://localhost:$HGPORT/' does not appear to be an hg repository:
                ---%<--- (application/mercuri)
                ---%<---
                !
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (859) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (836) Server: badhttpserver\r\n
                write(37 from 37) -> (799) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (758) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (737) Content-Length: 405\r\n
                write(2 from 2) -> (735) \r\n
                write(405 from 405) -> (330) lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (294) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (271) Server: badhttpserver\r\n
                write(37 from 37) -> (234) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (193) Content-Type: application/mercurial-0.1\r\n
                write(20 from 20) -> (173) Content-Length: 42\r\n
                write(2 from 2) -> (171) \r\n
                write(42 from 42) -> (129) 96ee1d7354c4ad7372047672c36a1f561e3a6a4c\n;
                readline(65537) -> (30) GET /?cmd=getbundle HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (396) x-hgarg-1: bundlecaps=HG20%2Cbundle2%3DHG20%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=1&common=0000000000000000000000000000000000000000&heads=96ee1d7354c4ad7372047672c36a1f561e3a6a4c&listkeys=phases%2Cbookmarks\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (93) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (70) Server: badhttpserver\r\n
                write(37 from 37) -> (33) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(33 from 41) -> (0) Content-Type: application/mercuri
                write limit reached; closing socket
                write(36) -> HTTP/1.1 500 Internal Server Error\r\n
                $ rm -f error.log
              Server sends empty HTTP body for getbundle
                $ hg --config badserver.closeaftersendbytes=933 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
-             TODO client spews a stack due to uncaught httplib.IncompleteRead
-               $ hg clone http://localhost:$HGPORT/ clone 2> /dev/null
+               $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               [1]
+               abort: HTTP request error (incomplete response)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
+               [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (897) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (874) Server: badhttpserver\r\n
                write(37 from 37) -> (837) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (796) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (775) Content-Length: 405\r\n
                write(2 from 2) -> (773) \r\n
                write(405 from 405) -> (368) lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (332) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (309) Server: badhttpserver\r\n
                write(37 from 37) -> (272) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (231) Content-Type: application/mercurial-0.1\r\n
                write(20 from 20) -> (211) Content-Length: 42\r\n
                write(2 from 2) -> (209) \r\n
                write(42 from 42) -> (167) 96ee1d7354c4ad7372047672c36a1f561e3a6a4c\n;
                readline(65537) -> (30) GET /?cmd=getbundle HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (396) x-hgarg-1: bundlecaps=HG20%2Cbundle2%3DHG20%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=1&common=0000000000000000000000000000000000000000&heads=96ee1d7354c4ad7372047672c36a1f561e3a6a4c&listkeys=phases%2Cbookmarks\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (131) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (108) Server: badhttpserver\r\n
                write(37 from 37) -> (71) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (30) Content-Type: application/mercurial-0.2\r\n
                write(28 from 28) -> (2) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (0) \r\n
                write limit reached; closing socket
                write(36) -> HTTP/1.1 500 Internal Server Error\r\n
                $ rm -f error.log
              Server sends partial compression string
                $ hg --config badserver.closeaftersendbytes=945 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
-             TODO client spews a stack due to uncaught httplib.IncompleteRead
-               $ hg clone http://localhost:$HGPORT/ clone 2> /dev/null
+               $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               [1]
+               abort: HTTP request error (incomplete response; expected 1 bytes got 3)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
+               [255]
                $ killdaemons.py $DAEMON_PIDS
                $ cat error.log
                readline(65537) -> (33) GET /?cmd=capabilities HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (8) vary: \r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (909) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (886) Server: badhttpserver\r\n
                write(37 from 37) -> (849) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (808) Content-Type: application/mercurial-0.1\r\n
                write(21 from 21) -> (787) Content-Length: 405\r\n
                write(2 from 2) -> (785) \r\n
                write(405 from 405) -> (380) lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batch streamreqs=generaldelta,revlogv1 bundle2=HG20%0Achangegroup%3D01%2C02%0Adigests%3Dmd5%2Csha1%2Csha512%0Aerror%3Dabort%2Cunsupportedcontent%2Cpushraced%2Cpushkey%0Ahgtagsfnodes%0Alistkeys%0Apushkey%0Aremote-changegroup%3Dhttp%2Chttps unbundle=HG10GZ,HG10BZ,HG10UN httpheader=1024 httpmediatype=0.1rx,0.1tx,0.2tx compression=none
                readline(65537) -> (26) GET /?cmd=batch HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (41) x-hgarg-1: cmds=heads+%3Bknown+nodes%3D\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (344) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (321) Server: badhttpserver\r\n
                write(37 from 37) -> (284) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (243) Content-Type: application/mercurial-0.1\r\n
                write(20 from 20) -> (223) Content-Length: 42\r\n
                write(2 from 2) -> (221) \r\n
                write(42 from 42) -> (179) 96ee1d7354c4ad7372047672c36a1f561e3a6a4c\n;
                readline(65537) -> (30) GET /?cmd=getbundle HTTP/1.1\r\n
                readline(-1) -> (27) Accept-Encoding: identity\r\n
                readline(-1) -> (29) vary: X-HgArg-1,X-HgProto-1\r\n
                readline(-1) -> (396) x-hgarg-1: bundlecaps=HG20%2Cbundle2%3DHG20%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=1&common=0000000000000000000000000000000000000000&heads=96ee1d7354c4ad7372047672c36a1f561e3a6a4c&listkeys=phases%2Cbookmarks\r\n
                readline(-1) -> (48) x-hgproto-1: 0.1 0.2 comp=zstd,zlib,none,bzip2\r\n
                readline(-1) -> (35) accept: application/mercurial-0.1\r\n
                readline(-1) -> (23) host: localhost:$HGPORT\r\n
                readline(-1) -> (49) user-agent: mercurial/proto-1.0 (Mercurial 4.2)\r\n
                readline(-1) -> (2) \r\n
                write(36 from 36) -> (143) HTTP/1.1 200 Script output follows\r\n
                write(23 from 23) -> (120) Server: badhttpserver\r\n
                write(37 from 37) -> (83) Date: Fri, 14 Apr 2017 00:00:00 GMT\r\n
                write(41 from 41) -> (42) Content-Type: application/mercurial-0.2\r\n
                write(28 from 28) -> (14) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (12) \r\n
                write(6 from 6) -> (6) 1\\r\\n\x04\\r\\n (esc)
                write(6 from 9) -> (0) 4\r\nnon
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server sends partial bundle2 header magic
                $ hg --config badserver.closeaftersendbytes=954 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               abort: connection ended unexpectedly
+               abort: HTTP request error (incomplete response; expected 1 bytes got 3)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -7 error.log
                write(28 from 28) -> (23) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (21) \r\n
                write(6 from 6) -> (15) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (6) 4\r\nnone\r\n
                write(6 from 9) -> (0) 4\r\nHG2
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server sends incomplete bundle2 stream params length
                $ hg --config badserver.closeaftersendbytes=963 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               abort: connection ended unexpectedly
+               abort: HTTP request error (incomplete response; expected 1 bytes got 3)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -8 error.log
                write(28 from 28) -> (32) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (30) \r\n
                write(6 from 6) -> (24) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (15) 4\r\nnone\r\n
                write(9 from 9) -> (6) 4\r\nHG20\r\n
                write(6 from 9) -> (0) 4\\r\\n\x00\x00\x00 (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Servers stops after bundle2 stream params header
                $ hg --config badserver.closeaftersendbytes=966 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               abort: connection ended unexpectedly
+               abort: HTTP request error (incomplete response)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -8 error.log
                write(28 from 28) -> (35) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (33) \r\n
                write(6 from 6) -> (27) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (18) 4\r\nnone\r\n
                write(9 from 9) -> (9) 4\r\nHG20\r\n
                write(9 from 9) -> (0) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops sending after bundle2 part header length
                $ hg --config badserver.closeaftersendbytes=975 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
-               abort: connection ended unexpectedly
+               abort: HTTP request error (incomplete response)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -9 error.log
                write(28 from 28) -> (44) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (42) \r\n
                write(6 from 6) -> (36) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (27) 4\r\nnone\r\n
                write(9 from 9) -> (18) 4\r\nHG20\r\n
                write(9 from 9) -> (9) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (0) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops sending after bundle2 part header
                $ hg --config badserver.closeaftersendbytes=1022 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                transaction abort!
                rollback completed
                abort: stream ended unexpectedly (got 0 bytes, expected 4)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -10 error.log
                write(28 from 28) -> (91) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (89) \r\n
                write(6 from 6) -> (83) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (74) 4\r\nnone\r\n
                write(9 from 9) -> (65) 4\r\nHG20\r\n
                write(9 from 9) -> (56) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (47) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (0) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops after bundle2 part payload chunk size
                $ hg --config badserver.closeaftersendbytes=1031 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                transaction abort!
                rollback completed
                abort: stream ended unexpectedly (got 0 bytes, expected 4)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -11 error.log
                write(28 from 28) -> (100) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (98) \r\n
                write(6 from 6) -> (92) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (83) 4\r\nnone\r\n
                write(9 from 9) -> (74) 4\r\nHG20\r\n
                write(9 from 9) -> (65) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (56) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (9) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write(9 from 9) -> (0) 4\\r\\n\x00\x00\x01\xd2\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops sending in middle of bundle2 payload chunk
                $ hg --config badserver.closeaftersendbytes=1504 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                transaction abort!
                rollback completed
                abort: stream ended unexpectedly (got 0 bytes, expected 4)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -12 error.log
                write(28 from 28) -> (573) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (571) \r\n
                write(6 from 6) -> (565) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (556) 4\r\nnone\r\n
                write(9 from 9) -> (547) 4\r\nHG20\r\n
                write(9 from 9) -> (538) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (529) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (482) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write(9 from 9) -> (473) 4\\r\\n\x00\x00\x01\xd2\\r\\n (esc)
                write(473 from 473) -> (0) 1d2\\r\\n\x00\x00\x00\xb2\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00>6a3df4de388f3c4f8e28f4f9a814299a3cbb5f50\\ntest\\n0 0\\nfoo\\n\\ninitial\x00\x00\x00\x00\x00\x00\x00\xa1j=\xf4\xde8\x8f<O\x8e(\xf4\xf9\xa8\x14)\x9a<\xbb_P\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00b80de5d138758541c5f05265ad144ab9fa86d1db\\n\x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00h\xb8\\r\xe5\xd18u\x85A\xc5\xf0Re\xad\x14J\xb9\xfa\x86\xd1\xdb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops sending after 0 length payload chunk size
                $ hg --config badserver.closeaftersendbytes=1513 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                adding manifests
                adding file changes
                added 1 changesets with 1 changes to 1 files
                transaction abort!
                rollback completed
-               abort: connection ended unexpectedly
+               abort: HTTP request error (incomplete response)
+               (this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)
                [255]
                $ killdaemons.py $DAEMON_PIDS
                $ tail -13 error.log
                write(28 from 28) -> (582) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (580) \r\n
                write(6 from 6) -> (574) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (565) 4\r\nnone\r\n
                write(9 from 9) -> (556) 4\r\nHG20\r\n
                write(9 from 9) -> (547) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (538) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (491) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write(9 from 9) -> (482) 4\\r\\n\x00\x00\x01\xd2\\r\\n (esc)
                write(473 from 473) -> (9) 1d2\\r\\n\x00\x00\x00\xb2\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00>6a3df4de388f3c4f8e28f4f9a814299a3cbb5f50\\ntest\\n0 0\\nfoo\\n\\ninitial\x00\x00\x00\x00\x00\x00\x00\xa1j=\xf4\xde8\x8f<O\x8e(\xf4\xf9\xa8\x14)\x9a<\xbb_P\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00b80de5d138758541c5f05265ad144ab9fa86d1db\\n\x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00h\xb8\\r\xe5\xd18u\x85A\xc5\xf0Re\xad\x14J\xb9\xfa\x86\xd1\xdb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (0) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
              Server stops sending after 0 part bundle part header (indicating end of bundle2 payload)
              This is before the 0 size chunked transfer part that signals end of HTTP response.
                $ hg --config badserver.closeaftersendbytes=1710 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                adding manifests
                adding file changes
                added 1 changesets with 1 changes to 1 files
                updating to branch default
 files updated, 0 files merged, 0 files removed, 0 files unresolved
                $ killdaemons.py $DAEMON_PIDS
                $ tail -22 error.log
                write(28 from 28) -> (779) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (777) \r\n
                write(6 from 6) -> (771) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (762) 4\r\nnone\r\n
                write(9 from 9) -> (753) 4\r\nHG20\r\n
                write(9 from 9) -> (744) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (735) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (688) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write(9 from 9) -> (679) 4\\r\\n\x00\x00\x01\xd2\\r\\n (esc)
                write(473 from 473) -> (206) 1d2\\r\\n\x00\x00\x00\xb2\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00>6a3df4de388f3c4f8e28f4f9a814299a3cbb5f50\\ntest\\n0 0\\nfoo\\n\\ninitial\x00\x00\x00\x00\x00\x00\x00\xa1j=\xf4\xde8\x8f<O\x8e(\xf4\xf9\xa8\x14)\x9a<\xbb_P\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00b80de5d138758541c5f05265ad144ab9fa86d1db\\n\x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00h\xb8\\r\xe5\xd18u\x85A\xc5\xf0Re\xad\x14J\xb9\xfa\x86\xd1\xdb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (197) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (188) 4\\r\\n\x00\x00\x00 \\r\\n (esc)
                write(38 from 38) -> (150) 20\\r\\n\x08LISTKEYS\x00\x00\x00\x01\x01\x00	\x06namespacephases\\r\\n (esc)
                write(9 from 9) -> (141) 4\\r\\n\x00\x00\x00:\\r\\n (esc)
                write(64 from 64) -> (77) 3a\r\n96ee1d7354c4ad7372047672c36a1f561e3a6a4c	1\npublishing	True\r\n
                write(9 from 9) -> (68) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (59) 4\\r\\n\x00\x00\x00#\\r\\n (esc)
                write(41 from 41) -> (18) 23\\r\\n\x08LISTKEYS\x00\x00\x00\x02\x01\x00		namespacebookmarks\\r\\n (esc)
                write(9 from 9) -> (9) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (0) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
                $ rm -rf clone
              Server sends a size 0 chunked-transfer size without terminating \r\n
                $ hg --config badserver.closeaftersendbytes=1713 serve -p $HGPORT -d --pid-file=hg.pid -E error.log
                $ cat hg.pid > $DAEMON_PIDS
                $ hg clone http://localhost:$HGPORT/ clone
                requesting all changes
                adding changesets
                adding manifests
                adding file changes
                added 1 changesets with 1 changes to 1 files
                updating to branch default
 files updated, 0 files merged, 0 files removed, 0 files unresolved
                $ killdaemons.py $DAEMON_PIDS
                $ tail -23 error.log
                write(28 from 28) -> (782) Transfer-Encoding: chunked\r\n
                write(2 from 2) -> (780) \r\n
                write(6 from 6) -> (774) 1\\r\\n\x04\\r\\n (esc)
                write(9 from 9) -> (765) 4\r\nnone\r\n
                write(9 from 9) -> (756) 4\r\nHG20\r\n
                write(9 from 9) -> (747) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (738) 4\\r\\n\x00\x00\x00)\\r\\n (esc)
                write(47 from 47) -> (691) 29\\r\\n\x0bCHANGEGROUP\x00\x00\x00\x00\x01\x01\x07\x02	\x01version02nbchanges1\\r\\n (esc)
                write(9 from 9) -> (682) 4\\r\\n\x00\x00\x01\xd2\\r\\n (esc)
                write(473 from 473) -> (209) 1d2\\r\\n\x00\x00\x00\xb2\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00>6a3df4de388f3c4f8e28f4f9a814299a3cbb5f50\\ntest\\n0 0\\nfoo\\n\\ninitial\x00\x00\x00\x00\x00\x00\x00\xa1j=\xf4\xde8\x8f<O\x8e(\xf4\xf9\xa8\x14)\x9a<\xbb_P\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00-foo\x00b80de5d138758541c5f05265ad144ab9fa86d1db\\n\x00\x00\x00\x00\x00\x00\x00\x07foo\x00\x00\x00h\xb8\\r\xe5\xd18u\x85A\xc5\xf0Re\xad\x14J\xb9\xfa\x86\xd1\xdb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x96\xee\x1dsT\xc4\xadsr\x04vr\xc3j\x1fV\x1e:jL\x00\x00\x00\x00\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (200) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (191) 4\\r\\n\x00\x00\x00 \\r\\n (esc)
                write(38 from 38) -> (153) 20\\r\\n\x08LISTKEYS\x00\x00\x00\x01\x01\x00	\x06namespacephases\\r\\n (esc)
                write(9 from 9) -> (144) 4\\r\\n\x00\x00\x00:\\r\\n (esc)
                write(64 from 64) -> (80) 3a\r\n96ee1d7354c4ad7372047672c36a1f561e3a6a4c	1\npublishing	True\r\n
                write(9 from 9) -> (71) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (62) 4\\r\\n\x00\x00\x00#\\r\\n (esc)
                write(41 from 41) -> (21) 23\\r\\n\x08LISTKEYS\x00\x00\x00\x02\x01\x00		namespacebookmarks\\r\\n (esc)
                write(9 from 9) -> (12) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(9 from 9) -> (3) 4\\r\\n\x00\x00\x00\x00\\r\\n (esc)
                write(3 from 5) -> (0) 0\r\n
                write limit reached; closing socket
                write(27) -> 15\r\nInternal Server Error\r\n
                $ rm -f error.log
                $ rm -rf clone

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages