Show More
@@ -56,19 +56,19 b' class sshpeer(wireproto.wirepeer):' | |||||
56 | if res != 0: |
|
56 | if res != 0: | |
57 | self._abort(error.RepoError(_("could not create remote repo"))) |
|
57 | self._abort(error.RepoError(_("could not create remote repo"))) | |
58 |
|
58 | |||
59 |
self.validate |
|
59 | self._validaterepo(sshcmd, args, remotecmd) | |
60 |
|
60 | |||
61 | def url(self): |
|
61 | def url(self): | |
62 | return self._url |
|
62 | return self._url | |
63 |
|
63 | |||
64 |
def validate |
|
64 | def _validaterepo(self, sshcmd, args, remotecmd): | |
65 | # cleanup up previous run |
|
65 | # cleanup up previous run | |
66 | self.cleanup() |
|
66 | self.cleanup() | |
67 |
|
67 | |||
68 | cmd = '%s %s %s' % (sshcmd, args, |
|
68 | cmd = '%s %s %s' % (sshcmd, args, | |
69 | util.shellquote("%s -R %s serve --stdio" % |
|
69 | util.shellquote("%s -R %s serve --stdio" % | |
70 | (_serverquote(remotecmd), _serverquote(self.path)))) |
|
70 | (_serverquote(remotecmd), _serverquote(self.path)))) | |
71 | ui.note(_('running %s\n') % cmd) |
|
71 | self.ui.note(_('running %s\n') % cmd) | |
72 | cmd = util.quotecommand(cmd) |
|
72 | cmd = util.quotecommand(cmd) | |
73 |
|
73 | |||
74 | # while self.subprocess isn't used, having it allows the subprocess to |
|
74 | # while self.subprocess isn't used, having it allows the subprocess to | |
@@ -86,7 +86,7 b' class sshpeer(wireproto.wirepeer):' | |||||
86 | if lines[-1] == "1\n" and l == "\n": |
|
86 | if lines[-1] == "1\n" and l == "\n": | |
87 | break |
|
87 | break | |
88 | if l: |
|
88 | if l: | |
89 | ui.debug("remote: ", l) |
|
89 | self.ui.debug("remote: ", l) | |
90 | lines.append(l) |
|
90 | lines.append(l) | |
91 | max_noise -= 1 |
|
91 | max_noise -= 1 | |
92 | else: |
|
92 | else: |
General Comments 0
You need to be logged in to leave comments.
Login now