opt

flandre/launcher.py

@@ -43,7 +43,6 @@ def launch(arg: dict[LaunchComponent, dict]):
     multiprocessing.set_start_method('spawn')
     bp = multiprocessing.Process(target=Broker(broker=True))
     bp.start()
-    # time.sleep(1)
     ps = []
     for k, v in arg.items():
         if k == LaunchComponent.MainUI and os.environ.get('XDG_CURRENT_DESKTOP', None) == 'KDE':
@@ -66,8 +65,8 @@ def launch(arg: dict[LaunchComponent, dict]):
                 break
         if isinstance(msg, TickMsg):
             cnt += 1
-            logging.error(f'{cnt}')
             if cnt == len(ps):
+                logging.info(f'launcher stand by ready')
                 c.send(Msg1())
 
     for p in pps:

flandre/nodes/Beamformer.py

@@ -2,7 +2,6 @@ import logging
 import time
 
 import cupy as cp
-import cv2
 import zmq
 
 from flandre.beamformer.das import gen_pwi
@@ -10,8 +9,7 @@ from flandre.beamformer.dist import direct_dist
 from flandre.config import C
 from flandre.nodes.Node import Node
 from flandre.utils.Config import DeviceConfig
-from flandre.utils.Msg import ImageArgMsg, Msg, BeamformerMsg, \
+from flandre.utils.Msg import ImageArgMsg, Msg, BeamformerMsg, RfMatMsg, RfFrameMsg
-    SeqMetaMsg, RfMatMsg, RGB888Msg, RfFrameMsg
 from flandre.utils.RfMat import RfMat
 from flandre.utils.RfMeta import RfSequenceMeta
 

flandre/nodes/Loader.py

@@ -1,5 +1,4 @@
 import logging
-import time
 from pathlib import Path
 
 import zmq

flandre/nodes/Node.py

@@ -60,7 +60,7 @@ class Node:
     def __call__(self, *args, **kwargs):
         self.setup()
         if not self.broker:
-            time.sleep(1)
+            time.sleep(0.2)
             self.send(TickMsg())
             self.recv()
         self.loop()

flandre/nodes/Recorder.py

@@ -1,6 +1,5 @@
 import logging
 import struct
-import time
 from pathlib import Path
 
 import numpy as np