equal
deleted
inserted
replaced
12 import threading |
12 import threading |
13 |
13 |
14 from .i18n import _ |
14 from .i18n import _ |
15 from .thirdparty import ( |
15 from .thirdparty import ( |
16 cbor, |
16 cbor, |
17 ) |
|
18 from .thirdparty.zope import ( |
|
19 interface as zi, |
|
20 ) |
17 ) |
21 from . import ( |
18 from . import ( |
22 encoding, |
19 encoding, |
23 error, |
20 error, |
24 hook, |
21 hook, |
27 wireprototypes, |
24 wireprototypes, |
28 wireprotov1server, |
25 wireprotov1server, |
29 wireprotov2server, |
26 wireprotov2server, |
30 ) |
27 ) |
31 from .utils import ( |
28 from .utils import ( |
|
29 interfaceutil, |
32 procutil, |
30 procutil, |
33 ) |
31 ) |
34 |
32 |
35 stringio = util.stringio |
33 stringio = util.stringio |
36 |
34 |
60 chunks.append(pycompat.bytesurl(v)) |
58 chunks.append(pycompat.bytesurl(v)) |
61 i += 1 |
59 i += 1 |
62 |
60 |
63 return ''.join(chunks) |
61 return ''.join(chunks) |
64 |
62 |
65 @zi.implementer(wireprototypes.baseprotocolhandler) |
63 @interfaceutil.implementer(wireprototypes.baseprotocolhandler) |
66 class httpv1protocolhandler(object): |
64 class httpv1protocolhandler(object): |
67 def __init__(self, req, ui, checkperm): |
65 def __init__(self, req, ui, checkperm): |
68 self._req = req |
66 self._req = req |
69 self._ui = ui |
67 self._ui = ui |
70 self._checkperm = checkperm |
68 self._checkperm = checkperm |
487 ferr.write(b'%s\n-\n' % rsp) |
485 ferr.write(b'%s\n-\n' % rsp) |
488 ferr.flush() |
486 ferr.flush() |
489 fout.write(b'\n') |
487 fout.write(b'\n') |
490 fout.flush() |
488 fout.flush() |
491 |
489 |
492 @zi.implementer(wireprototypes.baseprotocolhandler) |
490 @interfaceutil.implementer(wireprototypes.baseprotocolhandler) |
493 class sshv1protocolhandler(object): |
491 class sshv1protocolhandler(object): |
494 """Handler for requests services via version 1 of SSH protocol.""" |
492 """Handler for requests services via version 1 of SSH protocol.""" |
495 def __init__(self, ui, fin, fout): |
493 def __init__(self, ui, fin, fout): |
496 self._ui = ui |
494 self._ui = ui |
497 self._fin = fin |
495 self._fin = fin |