mirror of
https://gitflic.ru/project/openide/openide.git
synced 2026-01-08 15:09:39 +07:00
25248e839a
Move ThriftAbstractGetValueAsyncThread and ThriftGetValueAsyncThreadConsole from pydevd_comm.py to pydev_console_commands.py.
42 lines
1.5 KiB
Python
42 lines
1.5 KiB
Python
from _pydevd_bundle import pydevd_thrift
|
|
from _pydevd_bundle.pydevd_comm import PyDBDaemonThread
|
|
from _pydevd_bundle.pydevd_comm import threading
|
|
from _pydevd_bundle.pydevd_comm import time
|
|
from _pydevd_bundle.pydevd_constants import ASYNC_EVAL_TIMEOUT_SEC
|
|
|
|
|
|
class ThriftAbstractGetValueAsyncThread(PyDBDaemonThread):
|
|
"""
|
|
Abstract class for a thread, which evaluates values for async variables
|
|
"""
|
|
def __init__(self, server, seq, var_objects):
|
|
PyDBDaemonThread.__init__(self)
|
|
self.server = server
|
|
self.seq = seq
|
|
self.var_objs = var_objects
|
|
self.cancel_event = threading.Event()
|
|
|
|
def send_result(self, xml):
|
|
raise NotImplementedError()
|
|
|
|
def _on_run(self):
|
|
start = time.time()
|
|
values = []
|
|
for (var_obj, name) in self.var_objs:
|
|
current_time = time.time()
|
|
if current_time - start > ASYNC_EVAL_TIMEOUT_SEC or self.cancel_event.is_set():
|
|
break
|
|
# pydev_console_thrift.DebugValue()
|
|
values.append(pydevd_thrift.var_to_struct(var_obj, name, evaluate_full_value=True))
|
|
self.send_result(values)
|
|
|
|
|
|
class ThriftGetValueAsyncThreadConsole(ThriftAbstractGetValueAsyncThread):
|
|
"""
|
|
A thread for evaluation async values, which returns result for Console
|
|
Send result directly to Console's server
|
|
"""
|
|
def send_result(self, values):
|
|
if self.server is not None:
|
|
self.server.returnFullValue(self.seq, values)
|