Show More
@@ -382,7 +382,7 b' def parsev1commandresponse(ui, baseurl, ' | |||||
382 |
|
382 | |||
383 | class httppeer(wireprotov1peer.wirepeer): |
|
383 | class httppeer(wireprotov1peer.wirepeer): | |
384 | def __init__(self, ui, path, url, opener, requestbuilder, caps): |
|
384 | def __init__(self, ui, path, url, opener, requestbuilder, caps): | |
385 | self.ui = ui |
|
385 | super().__init__(ui) | |
386 | self._path = path |
|
386 | self._path = path | |
387 | self._url = url |
|
387 | self._url = url | |
388 | self._caps = caps |
|
388 | self._caps = caps |
@@ -387,6 +387,12 b' class peer:' | |||||
387 |
|
387 | |||
388 | limitedarguments = False |
|
388 | limitedarguments = False | |
389 |
|
389 | |||
|
390 | def __init__( | |||
|
391 | self, | |||
|
392 | ui, | |||
|
393 | ): | |||
|
394 | self.ui = ui | |||
|
395 | ||||
390 | def capable(self, name): |
|
396 | def capable(self, name): | |
391 | caps = self.capabilities() |
|
397 | caps = self.capabilities() | |
392 | if name in caps: |
|
398 | if name in caps: |
@@ -304,12 +304,11 b' class localpeer(repository.peer):' | |||||
304 | '''peer for a local repo; reflects only the most recent API''' |
|
304 | '''peer for a local repo; reflects only the most recent API''' | |
305 |
|
305 | |||
306 | def __init__(self, repo, caps=None): |
|
306 | def __init__(self, repo, caps=None): | |
307 | super(localpeer, self).__init__() |
|
307 | super(localpeer, self).__init__(repo.ui) | |
308 |
|
308 | |||
309 | if caps is None: |
|
309 | if caps is None: | |
310 | caps = moderncaps.copy() |
|
310 | caps = moderncaps.copy() | |
311 | self._repo = repo.filtered(b'served') |
|
311 | self._repo = repo.filtered(b'served') | |
312 | self.ui = repo.ui |
|
|||
313 |
|
312 | |||
314 | if repo._wanted_sidedata: |
|
313 | if repo._wanted_sidedata: | |
315 | formatted = bundle2.format_remote_wanted_sidedata(repo) |
|
314 | formatted = bundle2.format_remote_wanted_sidedata(repo) |
@@ -383,8 +383,8 b' class sshv1peer(wireprotov1peer.wirepeer' | |||||
383 | ``autoreadstderr`` denotes whether to automatically read from |
|
383 | ``autoreadstderr`` denotes whether to automatically read from | |
384 | stderr and to forward its output. |
|
384 | stderr and to forward its output. | |
385 | """ |
|
385 | """ | |
|
386 | super().__init__(ui) | |||
386 | self._url = url |
|
387 | self._url = url | |
387 | self.ui = ui |
|
|||
388 | # self._subprocess is unused. Keeping a handle on the process |
|
388 | # self._subprocess is unused. Keeping a handle on the process | |
389 | # holds a reference and prevents it from being garbage collected. |
|
389 | # holds a reference and prevents it from being garbage collected. | |
390 | self._subprocess = proc |
|
390 | self._subprocess = proc |
General Comments 0
You need to be logged in to leave comments.
Login now