equal
deleted
inserted
replaced
73 l = r.readline() |
73 l = r.readline() |
74 self.readerr() |
74 self.readerr() |
75 if lines[-1] == "1\n" and l == "\n": |
75 if lines[-1] == "1\n" and l == "\n": |
76 break |
76 break |
77 if l: |
77 if l: |
78 ui.debug(_("remote: "), l) |
78 ui.debug("remote: ", l) |
79 lines.append(l) |
79 lines.append(l) |
80 max_noise -= 1 |
80 max_noise -= 1 |
81 else: |
81 else: |
82 self.abort(error.RepoError(_("no suitable response from remote hg"))) |
82 self.abort(error.RepoError(_("no suitable response from remote hg"))) |
83 |
83 |
111 pass |
111 pass |
112 |
112 |
113 __del__ = cleanup |
113 __del__ = cleanup |
114 |
114 |
115 def do_cmd(self, cmd, **args): |
115 def do_cmd(self, cmd, **args): |
116 self.ui.debug(_("sending %s command\n") % cmd) |
116 self.ui.debug("sending %s command\n" % cmd) |
117 self.pipeo.write("%s\n" % cmd) |
117 self.pipeo.write("%s\n" % cmd) |
118 for k, v in args.iteritems(): |
118 for k, v in args.iteritems(): |
119 self.pipeo.write("%s %d\n" % (k, len(v))) |
119 self.pipeo.write("%s %d\n" % (k, len(v))) |
120 self.pipeo.write(v) |
120 self.pipeo.write(v) |
121 self.pipeo.flush() |
121 self.pipeo.flush() |