86             if l.startswith("capabilities:"):

    86             if l.startswith("capabilities:"):

    87                 self.capabilities.update(l[:-1].split(":")[1].split())

    87                 self.capabilities.update(l[:-1].split(":")[1].split())

    88                 break

    88                 break

    89 

    89 

    90     def readerr(self):

    90     def readerr(self):

    92             size = util.fstat(self.pipee).st_size

    92             size = util.fstat(self.pipee).st_size

    93             if size == 0:

    93             if size == 0:

    94                 break

    94                 break

    95             s = self.pipee.read(size)

    95             s = self.pipee.read(size)

    96             if not s:

    96             if not s:

   146 

   146 

   147     def _callpush(self, cmd, fp, **args):

   147     def _callpush(self, cmd, fp, **args):

   148         r = self._call(cmd, **args)

   148         r = self._call(cmd, **args)

   149         if r:

   149         if r:

   150             return '', r

   150             return '', r

   152             d = fp.read(4096)

   152             d = fp.read(4096)

   153             if not d:

   153             if not d:

   154                 break

   154                 break

   155             self._send(d)

   155             self._send(d)

   156         self._send("", flush=True)

   156         self._send("", flush=True)

   191         similar to unbundle(). DEPRECATED, since it requires locking the

   191         similar to unbundle(). DEPRECATED, since it requires locking the

   192         remote.'''

   192         remote.'''

   193         d = self._call("addchangegroup")

   193         d = self._call("addchangegroup")

   194         if d:

   194         if d:

   195             self._abort(error.RepoError(_("push refused: %s") % d))

   195             self._abort(error.RepoError(_("push refused: %s") % d))

   197             d = cg.read(4096)

   197             d = cg.read(4096)

   198             if not d:

   198             if not d:

   199                 break

   199                 break

   200             self.pipeo.write(d)

   200             self.pipeo.write(d)

   201             self.readerr()

   201             self.readerr()