This is an archive of the discontinued Mercurial Phabricator instance.

Differential D4437

httppeer: log commands for version 2 peer
ClosedPublic

Authored by indygreg on Aug 31 2018, 6:57 PM.

Details

Reviewers
pulkit
Group Reviewers
hg-reviewers
Commits
rHG3fe028b657bf: httppeer: log commands for version 2 peer
Summary

This will aid testing and debugging.

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.

Revision Contents
Changeset List

PathPackages
Mmercurial/httppeer.py (4 lines)

Diff 10757

mercurial/httppeer.py

wireprotoframing, wireprotoframing,
wireprototypes, wireprototypes,
wireprotov1peer, wireprotov1peer,
wireprotov2peer, wireprotov2peer,
wireprotov2server, wireprotov2server,
) )
from .utils import ( from .utils import (
interfaceutil, interfaceutil,
stringutil,
) )
httplib = util.httplib httplib = util.httplib
urlerr = util.urlerr urlerr = util.urlerr
urlreq = util.urlreq urlreq = util.urlreq
def encodevalueinheaders(value, header, limit): def encodevalueinheaders(value, header, limit):
"""Encode a string value into multiple HTTP headers. """Encode a string value into multiple HTTP headers.
url = '%s/%s' % (apiurl, permission) url = '%s/%s' % (apiurl, permission)
if len(requests) > 1: if len(requests) > 1:
url += '/multirequest' url += '/multirequest'
else: else:
url += '/%s' % requests[0][0] url += '/%s' % requests[0][0]
ui.debug('sending %d commands\n' % len(requests))
for command, args, f in requests: for command, args, f in requests:
ui.debug('sending command %s: %s\n' % (
command, stringutil.pprint(args, indent=2)))
assert not list(handler.callcommand(command, args, f)) assert not list(handler.callcommand(command, args, f))
# TODO stream this. # TODO stream this.
body = b''.join(map(bytes, handler.flushcommands())) body = b''.join(map(bytes, handler.flushcommands()))
# TODO modify user-agent to reflect v2 # TODO modify user-agent to reflect v2
headers = { headers = {
r'Accept': wireprotov2server.FRAMINGTYPE, r'Accept': wireprotov2server.FRAMINGTYPE,