From ad1c9ef675e29c5d6751dc2226e761172f853bf7 Mon Sep 17 00:00:00 2001 From: flandre Date: Fri, 17 Jan 2025 12:58:08 +0800 Subject: [PATCH] fix --- src/nodes/Beamformer.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/nodes/Beamformer.py b/src/nodes/Beamformer.py index ac415dd..a02bd9a 100644 --- a/src/nodes/Beamformer.py +++ b/src/nodes/Beamformer.py @@ -5,6 +5,8 @@ import zmq from utils.Msg import BMMsg, ImageArgMsg, KillMsg from config import SOCKET1, VIDEO_WIDTH, VIDEO_HEIGHT from nodes.Node import Node +from utils.RfFile import RfFrame, RfSequenceMeta +from utils.RfMat import RfMat class Beamformer(Node): @@ -39,6 +41,11 @@ class Beamformer(Node): socks = dict(self.c.poller.poll()) if s2 in socks and socks[s2] == zmq.POLLIN: buffer = s2.recv() + + RfMat(1, RfFrame.RfFrameMeta( + 1, 1 + ), RfSequenceMeta()) + if self.c.sub in socks and socks[self.c.sub] == zmq.POLLIN: r = self.recv() if isinstance(r, KillMsg):