139 def changegroup(self, nodes, kind): |
139 def changegroup(self, nodes, kind): |
140 n = " ".join(map(hex, nodes)) |
140 n = " ".join(map(hex, nodes)) |
141 f = self.do_cmd("changegroup", roots=n) |
141 f = self.do_cmd("changegroup", roots=n) |
142 return self.pipei |
142 return self.pipei |
143 |
143 |
|
144 def unbundle(self, cg, heads, source): |
|
145 d = self.call("unbundle", heads=' '.join(map(hex, heads))) |
|
146 if d: |
|
147 raise hg.RepoError(_("push refused: %s") % d) |
|
148 |
|
149 while 1: |
|
150 d = cg.read(4096) |
|
151 if not d: break |
|
152 self.pipeo.write(str(len(d)) + '\n') |
|
153 self.pipeo.write(d) |
|
154 self.readerr() |
|
155 |
|
156 self.pipeo.write('0\n') |
|
157 self.pipeo.flush() |
|
158 |
|
159 self.readerr() |
|
160 d = self.pipei.readline() |
|
161 if d != '\n': |
|
162 return 1 |
|
163 |
|
164 l = int(self.pipei.readline()) |
|
165 r = self.pipei.read(l) |
|
166 if not r: |
|
167 return 1 |
|
168 return int(r) |
|
169 |
144 def addchangegroup(self, cg, source): |
170 def addchangegroup(self, cg, source): |
145 d = self.call("addchangegroup") |
171 d = self.call("addchangegroup") |
146 if d: |
172 if d: |
147 raise hg.RepoError(_("push refused: %s") % d) |
173 raise hg.RepoError(_("push refused: %s") % d) |
148 |
|
149 while 1: |
174 while 1: |
150 d = cg.read(4096) |
175 d = cg.read(4096) |
151 if not d: break |
176 if not d: break |
152 self.pipeo.write(d) |
177 self.pipeo.write(d) |
153 self.readerr() |
178 self.readerr() |