mercurial/httppeer.py

37320:39f7d4ee8bcd

            f.seek(0)
        self._index = 0

class httppeer(wireproto.wirepeer):
    def __init__(self, ui, path, url, opener):
        self._ui = ui
        self._path = path
        self._url = url
        self._caps = None
        self._urlopener = opener
        # This is an its own attribute to facilitate extensions overriding

        for h in self._urlopener.handlers:
            h.close()
            getattr(h, "close_all", lambda: None)()

    def _openurl(self, req):
        if (self._ui.debugflag
            and self._ui.configbool('devel', 'debug.peer-request')):
            dbg = self._ui.debug
            line = 'devel-peer-request: %s\n'
            dbg(line % '%s %s' % (req.get_method(), req.get_full_url()))
            hgargssize = None

            for header, value in sorted(req.header_items()):

                dbg(line % '  %d bytes of data' % length)

            start = util.timer()

        ret = self._urlopener.open(req)
        if self._ui.configbool('devel', 'debug.peer-request'):
            dbg(line % '  finished in %.4f seconds (%s)'
                % (util.timer() - start, ret.code))
        return ret

    # Begin of ipeerconnection interface.

    @util.propertycache
    def ui(self):
        return self._ui

    def url(self):
        return self._path

    def local(self):

37321:e826fe7a08c7

            f.seek(0)
        self._index = 0

class httppeer(wireproto.wirepeer):
    def __init__(self, ui, path, url, opener):
        self.ui = ui
        self._path = path
        self._url = url
        self._caps = None
        self._urlopener = opener
        # This is an its own attribute to facilitate extensions overriding

        for h in self._urlopener.handlers:
            h.close()
            getattr(h, "close_all", lambda: None)()

    def _openurl(self, req):
        if (self.ui.debugflag
            and self.ui.configbool('devel', 'debug.peer-request')):
            dbg = self.ui.debug
            line = 'devel-peer-request: %s\n'
            dbg(line % '%s %s' % (req.get_method(), req.get_full_url()))
            hgargssize = None

            for header, value in sorted(req.header_items()):

                dbg(line % '  %d bytes of data' % length)

            start = util.timer()

        ret = self._urlopener.open(req)
        if self.ui.configbool('devel', 'debug.peer-request'):
            dbg(line % '  finished in %.4f seconds (%s)'
                % (util.timer() - start, ret.code))
        return ret

    # Begin of ipeerconnection interface.

    def url(self):
        return self._path

    def local(self):