run gr_decoder on separate process

tools/client_server/gr_decoder.py

@@ -163,3 +163,24 @@ def process(fp: pathlib.Path, params: dict):
 
     x = executor.action()
     print(x)
+
+
+def _process(fp: pathlib.Path, params: dict, q: mp.Queue = None):
+    logger = logging.getLogger()
+    logger.handlers.clear()
+    logger.setLevel(mp.get_logger().level)
+    if q is not None:
+        qh = logging.handlers.QueueHandler(q)
+        logger.addHandler(qh)
+    log = logging.getLogger('GRProcess')
+
+    try:
+        process(fp, params)
+    except:
+        log.error('process error:', exc_info=True)
+
+
+def process2(fp: pathlib.Path, params: dict, log: logging.Logger = None):
+    p = mp.Process(target=_process, args=(fp, params, log))
+    p.start()
+    p.join()

tools/client_server/server.py

@@ -188,7 +188,7 @@ def action(self):
 
                 try:
                     self.log.info('Decode processing')
-                    gr_decoder.process(fp, params)
+                    gr_decoder.process2(fp, params, self.q)
                 except:
                     self.log.error('gr_decoder')