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