fix of debug_rpc
This commit is contained in:
@@ -141,7 +141,7 @@ class LuaFuncExecEngine:
|
|||||||
# POpen params
|
# POpen params
|
||||||
params = [self._lpath, "main.lua", "--timeout", f"{self._timeout}", "--host", "127.0.0.1", "--port", f"{self._port}"]
|
params = [self._lpath, "main.lua", "--timeout", f"{self._timeout}", "--host", "127.0.0.1", "--port", f"{self._port}"]
|
||||||
|
|
||||||
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
||||||
params.append("--verbose")
|
params.append("--verbose")
|
||||||
|
|
||||||
self._process = subprocess.Popen(
|
self._process = subprocess.Popen(
|
||||||
@@ -153,7 +153,7 @@ class LuaFuncExecEngine:
|
|||||||
sock.close()
|
sock.close()
|
||||||
|
|
||||||
self._rpc = JsonRpcClient("localhost", self._port, req_handler=self._req_handler)
|
self._rpc = JsonRpcClient("localhost", self._port, req_handler=self._req_handler)
|
||||||
if tm.debug_enabled():
|
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
||||||
self._rpc.dbg_out = sys.stdout
|
self._rpc.dbg_out = sys.stdout
|
||||||
self._rpc.start()
|
self._rpc.start()
|
||||||
|
|
||||||
|
|||||||
@@ -76,7 +76,7 @@ class PyFuncExecEngine:
|
|||||||
func_proc_path = tm.gd("testium_path")
|
func_proc_path = tm.gd("testium_path")
|
||||||
|
|
||||||
params = [self._ppath, "-m", "py_func", "-p", f"{self._port}", "-t", f"{self._timeout}"]
|
params = [self._ppath, "-m", "py_func", "-p", f"{self._port}", "-t", f"{self._timeout}"]
|
||||||
|
|
||||||
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
||||||
params.append("-v")
|
params.append("-v")
|
||||||
|
|
||||||
@@ -89,7 +89,7 @@ class PyFuncExecEngine:
|
|||||||
sock.close()
|
sock.close()
|
||||||
|
|
||||||
self._rpc = JsonRpcClient("localhost", self._port, req_handler=self._req_handler)
|
self._rpc = JsonRpcClient("localhost", self._port, req_handler=self._req_handler)
|
||||||
if tm.debug_enabled():
|
if tm.debug_enabled() and tm.gd("debug_rpc", False):
|
||||||
self._rpc.dbg_out = sys.stdout
|
self._rpc.dbg_out = sys.stdout
|
||||||
self._rpc.start()
|
self._rpc.start()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user