platformio/platformio-core
1
0
Fork 1
mirror of https://github.com/platformio/platformio-core.git synced 2025-07-30 01:57:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

Match buffered data from debugging server

Browse Source
This commit is contained in:
Ivan Kravets
2021-06-24 16:42:45 +03:00
parent 311e10f91e
commit 05374d1145
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
platformio/debug/process/server.py
View File

@ -26,10 +26,14 @@ from platformio.proc import where_is_program
class DebugServerProcess(DebugBaseProcess): class DebugServerProcess(DebugBaseProcess):
STD_BUFFER_SIZE = 1024
def __init__(self, debug_config): def __init__(self, debug_config):
super(DebugServerProcess, self).__init__() super(DebugServerProcess, self).__init__()
self.debug_config = debug_config self.debug_config = debug_config
self._ready = False self._ready = False
self._std_buffer = {"out": b"", "err": b""}
async def run(self): # pylint: disable=too-many-branches async def run(self): # pylint: disable=too-many-branches
server = self.debug_config.server server = self.debug_config.server
@ -133,8 +137,12 @@ class DebugServerProcess(DebugBaseProcess):
super(DebugServerProcess, self).stdout_data_received( super(DebugServerProcess, self).stdout_data_received(
escape_gdbmi_stream("@", data) if is_gdbmi_mode() else data escape_gdbmi_stream("@", data) if is_gdbmi_mode() else data
) )
self._check_ready_by_pattern(data) self._std_buffer["out"] += data
self._check_ready_by_pattern(self._std_buffer["out"])
self._std_buffer["out"] = self._std_buffer["out"][-1 * self.STD_BUFFER_SIZE :]
def stderr_data_received(self, data): def stderr_data_received(self, data):
super(DebugServerProcess, self).stderr_data_received(data) super(DebugServerProcess, self).stderr_data_received(data)
self._check_ready_by_pattern(data) self._std_buffer["err"] += data
self._check_ready_by_pattern(self._std_buffer["err"])
self._std_buffer["err"] = self._std_buffer["err"][-1 * self.STD_BUFFER_SIZE :]