feedc0de/platformio-core
1
0
Fork 0
forked from platformio/platformio-core
Code Pull Requests Activity

Do not remove thread buffers, reset them instead

Browse Source
This commit is contained in:
Ivan Kravets
2019-07-02 22:26:01 +03:00
parent 18d93dfcc9
commit 6c47c7506e
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
platformio/commands/home/rpc/handlers/piocore.py
View File

@ -49,14 +49,12 @@ class MultiThreadingStdStream(object):
return self._buffers[thread_id].write(
value.decode() if is_bytes(value) else value)
def get_value_and_close(self):
thread_id = thread_get_ident()
def get_value_and_reset(self):
result = ""
try:
result = self.getvalue()
self.close()
if thread_id in self._buffers:
del self._buffers[thread_id]
self.truncate(0)
self.seek(0)
except AttributeError:
pass
return result
@ -88,11 +86,10 @@ class PIOCoreRPC(object):
def _call_inline():
with util.cd((options or {}).get("cwd") or os.getcwd()):
exit_code = __main__.main(["-c"] + args)
return (PIOCoreRPC.thread_stdout.get_value_and_close(),
PIOCoreRPC.thread_stderr.get_value_and_close(), exit_code)
return (PIOCoreRPC.thread_stdout.get_value_and_reset(),
PIOCoreRPC.thread_stderr.get_value_and_reset(), exit_code)
d = threads.deferToThread(_call_inline)
d.addCallback(PIOCoreRPC._call_callback, "--json-output" in args)
d.addErrback(PIOCoreRPC._call_errback)
return d