Method pipe_process_output

src/execution/process_pty.py:69–148

(self)

        self.process.wait()

    def pipe_process_output(self):
        utf8_stream = self.encoding.lower() == 'utf-8'

        buffer = b''

        try:
            while True:
                finished = False
                wait_new_output = False

                max_read_bytes = 1024

                data = buffer
                buffer = b''

                if self.is_finished():
                    while True:
                        try:
                            chunk = os.read(self.pty_master, max_read_bytes)
                            if not chunk:
                                break
                            data += chunk

                        except BlockingIOError:
                            break

                    finished = True

                else:
                    try:
                        data += os.read(self.pty_master, max_read_bytes)
                        if data.endswith(b"\r"):
                            data += os.read(self.pty_master, 1)

                        if utf8_stream and data:
                            while data[len(data) - 1] >= 127:
                                next_byte = os.read(self.pty_master, 1)
                                if not next_byte:
                                    break

                                data += next_byte
                    except BlockingIOError:
                        if self.is_finished():
                            finished = True

                    if not data:
                        wait_new_output = True

                if utf8_stream and data:
                    while data and data[-1] >= 127:
                        buffer = bytes([data[-1]]) + buffer
                        data = data[:-1]

                if data:
                    try:
                        output_text = encoding_utils.decode(data, self.encoding)
                        self._write_script_output(output_text)
                    except UnicodeDecodeError: