comparison mercurial/ui.py @ 40520:fd60c2afb484

ui: factor out function that writes data to fout/ferr with labeling

I'm thinking of adding an option to send status messages to stderr (or a
dedicated command-server channel) so that structured output (e.g. JSON)
would never be interleaved with non-formatter output. A unified write()
interface helps to do that.

40519:3c4b9dace7de

                label = opts.get(r'label', '')
                self._buffers[-1].extend(self.label(a, label) for a in args)
            else:
                self._buffers[-1].extend(args)
        else:
            self._writenobuf(*args, **opts)

    def _writenobuf(self, *args, **opts):
        self._progclear()
        if self._colormode == 'win32':
            # windows color printing is its own can of crab, defer to
            # the color module and that is it.
            color.win32print(self, self._write, *args, **opts)
        else:
            msgs = args
            if self._colormode is not None:
                label = opts.get(r'label', '')
                msgs = [self.label(a, label) for a in args]
            self._write(*msgs, **opts)

    def _write(self, *msgs, **opts):
        # opencode timeblockedsection because this is a critical path
        starttime = util.timer()
        try:

                (util.timer() - starttime) * 1000

    def write_err(self, *args, **opts):
        if self._bufferstates and self._bufferstates[-1][0]:
            self.write(*args, **opts)
            return
        self._progclear()
        if self._colormode == 'win32':
            # windows color printing is its own can of crab, defer to
            # the color module and that is it.
            color.win32print(self, self._write_err, *args, **opts)
        else:
            msgs = args
            if self._colormode is not None:
                label = opts.get(r'label', '')
                msgs = [self.label(a, label) for a in args]
            self._write_err(*msgs, **opts)

    def _write_err(self, *msgs, **opts):
        try:
            with self.timeblockedsection('stdio'):
                if not getattr(self.fout, 'closed', False):

        If ui is not interactive, the default is returned.
        """
        if not self.interactive():
            self.write(msg, ' ', default or '', "\n")
            return default
        self._writenobuf(msg, label='ui.prompt')
        self.flush()
        try:
            r = self._readline()
            if not r:
                r = default

40520:fd60c2afb484

                label = opts.get(r'label', '')
                self._buffers[-1].extend(self.label(a, label) for a in args)
            else:
                self._buffers[-1].extend(args)
        else:
            self._writenobuf(self._write, *args, **opts)

    def _writenobuf(self, write, *args, **opts):
        self._progclear()
        if self._colormode == 'win32':
            # windows color printing is its own can of crab, defer to
            # the color module and that is it.
            color.win32print(self, write, *args, **opts)
        else:
            msgs = args
            if self._colormode is not None:
                label = opts.get(r'label', '')
                msgs = [self.label(a, label) for a in args]
            write(*msgs, **opts)

    def _write(self, *msgs, **opts):
        # opencode timeblockedsection because this is a critical path
        starttime = util.timer()
        try:

                (util.timer() - starttime) * 1000

    def write_err(self, *args, **opts):
        if self._bufferstates and self._bufferstates[-1][0]:
            self.write(*args, **opts)
        else:
            self._writenobuf(self._write_err, *args, **opts)

    def _write_err(self, *msgs, **opts):
        try:
            with self.timeblockedsection('stdio'):
                if not getattr(self.fout, 'closed', False):

        If ui is not interactive, the default is returned.
        """
        if not self.interactive():
            self.write(msg, ' ', default or '', "\n")
            return default
        self._writenobuf(self._write, msg, label='ui.prompt')
        self.flush()
        try:
            r = self._readline()
            if not r:
                r = default