|
@@ -87,12 +87,13 @@ def _start_on_daemon_thread(func, args):
|
|
|
thrd.start()
|
|
|
|
|
|
def boot_translation_service(controller):
|
|
|
- _start_on_daemon_thread(_poll, [controller, None])
|
|
|
-
|
|
|
-def _poll(controller, _):
|
|
|
socket_out = controller.addOutputListener("socket_out")
|
|
|
+ _start_on_daemon_thread(_poll, [controller, socket_out])
|
|
|
+
|
|
|
+def _poll(controller, socket_out):
|
|
|
while 1:
|
|
|
evt = socket_out.fetch(-1)
|
|
|
+ print("S2E got event " + str(evt))
|
|
|
name, params = evt.getName(), evt.getParameters()
|
|
|
if name == "accept_socket":
|
|
|
_start_on_daemon_thread(_accept, [controller, params[0]])
|
|
@@ -104,7 +105,9 @@ def _poll(controller, _):
|
|
|
sock = socket.socket()
|
|
|
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
|
|
start_socket_threads(controller, sock)
|
|
|
+ print("Raise created socket!")
|
|
|
controller.addInput(Event("created_socket", "socket_in", [sock, params[0]]))
|
|
|
+ print("raise OK")
|
|
|
elif name == "close_socket":
|
|
|
_start_on_daemon_thread(_close, [controller, params[0]])
|
|
|
elif name == "send_socket":
|