This commit is contained in:
flandre 2025-01-17 12:58:08 +08:00
parent 24892ea0ea
commit ad1c9ef675

View File

@ -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):