_frame_instrument.py 文件源码

def _frame_worker(self):
        if(getattr(self, '_frame_class', None)):
            ctx = zmq.Context.instance()
            skt = ctx.socket(zmq.SUB)
            skt.connect("tcp://%s:27185" % self._moku._ip)
            skt.setsockopt_string(zmq.SUBSCRIBE, u'')
            skt.setsockopt(zmq.RCVHWM, 8)
            skt.setsockopt(zmq.LINGER, 5000)

            fr = self._frame_class(**self._frame_kwargs)

            try:
                while self._running:
                    if skt in zmq.select([skt], [], [], 1.0)[0]:
                        d = skt.recv()
                        fr.add_packet(d)

                        if fr._complete:
                            self._queue.put_nowait(fr)
                            fr = self._frame_class(**self._frame_kwargs)
            finally:
                skt.close()