--- a/mercurial/wireprotoserver.py Sat Apr 13 03:44:47 2019 +0200
+++ b/mercurial/wireprotoserver.py Sat Apr 13 03:44:55 2019 +0200
@@ -446,7 +446,7 @@
pass
-def _runsshserver(ui, repo, fin, fout, ev):
+def _runsshserver(ui, repo, fin, fout, ev, accesshidden=False):
# This function operates like a state machine of sorts. The following
# states are defined:
#
@@ -487,7 +487,9 @@
_sshv1respondbytes(fout, b'')
continue
- rsp = wireprotov1server.dispatch(repo, proto, request)
+ rsp = wireprotov1server.dispatch(
+ repo, proto, request, accesshidden=accesshidden
+ )
repo.ui.fout.flush()
repo.ui.ferr.flush()
@@ -522,10 +524,11 @@
class sshserver:
- def __init__(self, ui, repo, logfh=None):
+ def __init__(self, ui, repo, logfh=None, accesshidden=False):
self._ui = ui
self._repo = repo
self._fin, self._fout = ui.protectfinout()
+ self._accesshidden = accesshidden
# Log write I/O to stdout and stderr if configured.
if logfh:
@@ -542,4 +545,6 @@
def serveuntil(self, ev):
"""Serve until a threading.Event is set."""
- _runsshserver(self._ui, self._repo, self._fin, self._fout, ev)
+ _runsshserver(
+ self._ui, self._repo, self._fin, self._fout, ev, self._accesshidden
+ )