165     def _recv(self):

   165     def _recv(self):

   166         l = self.pipei.readline()

   166         l = self.pipei.readline()

   167         self.readerr()

   167         self.readerr()

   168         try:

   168         try:

   169             l = int(l)

   169             l = int(l)

   171             self._abort(error.ResponseError(_("unexpected response:"), l))

   171             self._abort(error.ResponseError(_("unexpected response:"), l))

   172         return self.pipei.read(l)

   172         return self.pipei.read(l)

   173 

   173 

   174     def _send(self, data, flush=False):

   174     def _send(self, data, flush=False):

   175         self.pipeo.write("%d\n" % len(data))

   175         self.pipeo.write("%d\n" % len(data))

   206         r = self._recv()

   206         r = self._recv()

   207         if not r:

   207         if not r:

   208             return 1

   208             return 1

   209         try:

   209         try:

   210             return int(r)

   210             return int(r)

   212             self._abort(error.ResponseError(_("unexpected response:"), r))

   212             self._abort(error.ResponseError(_("unexpected response:"), r))

   213 

   213 

   214 instance = sshrepository

   214 instance = sshrepository