4159             # to bypass this layer and normalize to commands + args.

  4159             # to bypass this layer and normalize to commands + args.

  4160             ui.status(

  4160             ui.status(

  4161                 _(b'sending batch with %d sub-commands\n')

  4161                 _(b'sending batch with %d sub-commands\n')

  4162                 % len(batchedcommands)

  4162                 % len(batchedcommands)

  4163             )

  4163             )

  4164             for i, chunk in enumerate(peer._submitbatch(batchedcommands)):

  4165             for i, chunk in enumerate(peer._submitbatch(batchedcommands)):

  4165                 ui.status(

  4166                 ui.status(

  4166                     _(b'response #%d: %s\n') % (i, stringutil.escapestr(chunk))

  4167                     _(b'response #%d: %s\n') % (i, stringutil.escapestr(chunk))

  4167                 )

  4168                 )

  4168 

  4169 

  4239                         cborutil.decodeall(body), bprefix=True, indent=2

  4240                         cborutil.decodeall(body), bprefix=True, indent=2

  4240                     )

  4241                     )

  4241                 )

  4242                 )

  4242 

  4243 

  4243         elif action == b'close':

  4244         elif action == b'close':

  4244             peer.close()

  4246             peer.close()

  4245         elif action == b'readavailable':

  4247         elif action == b'readavailable':

  4246             if not stdout or not stderr:

  4248             if not stdout or not stderr:

  4247                 raise error.Abort(

  4249                 raise error.Abort(

  4248                     _(b'readavailable not available on this peer')

  4250                     _(b'readavailable not available on this peer')