##// END OF EJS Templates
localrepo: subclass the new `repository.ipeercommandexecutor` Protocol class...
Matt Harbison -
r53393:e123c8a2 default
parent child Browse files
Show More
@@ -344,6 +344,7 class ipeercommandexecutor(Protocol):
344 344 outstanding requests are waited on.
345 345 """
346 346
347 @abc.abstractmethod
347 348 def callcommand(self, name, args):
348 349 """Request that a named command be executed.
349 350
@@ -366,6 +367,7 class ipeercommandexecutor(Protocol):
366 367 until all command requests have been issued.
367 368 """
368 369
370 @abc.abstractmethod
369 371 def sendcommands(self):
370 372 """Trigger submission of queued command requests.
371 373
@@ -376,6 +378,7 class ipeercommandexecutor(Protocol):
376 378 When called, no more new commands may be issued with this executor.
377 379 """
378 380
381 @abc.abstractmethod
379 382 def close(self):
380 383 """Signal that this command request is finished.
381 384
@@ -258,7 +258,7 moderncaps = {
258 258 legacycaps = moderncaps.union({b'changegroupsubset'})
259 259
260 260
261 class localcommandexecutor: # (repository.ipeercommandexecutor)
261 class localcommandexecutor(repository.ipeercommandexecutor):
262 262 def __init__(self, peer):
263 263 self._peer = peer
264 264 self._sent = False
@@ -107,8 +107,7 class unsentfuture(futures.Future):
107 107 return self.result(timeout)
108 108
109 109
110 # @interfaceutil.implementer(repository.ipeercommandexecutor)
111 class peerexecutor:
110 class peerexecutor(repository.ipeercommandexecutor):
112 111 def __init__(self, peer):
113 112 self._peer = peer
114 113 self._sent = False
General Comments 0
You need to be logged in to leave comments. Login now