irrad_control/irrad_interpreter.py
def _setup_interpreter(self):
        """Sets up the main zmq context and the sockets which are accessed within this process.
        This needs to be called within the run-method"""

        # Create main context for this process; sockets need to be created on their respective threads!
        self.context = zmq.Context()

        # Create PUB socket in order to send interpreted data
        self.data_pub = self.context.socket(zmq.PUB)
        self.data_pub.set_hwm(10)  # drop data if too slow
        self.data_pub.bind(self._tcp_addr(self.setup['port']['data']))

        # Start logging
        self._setup_logging()

        # Start daq
        self._setup_daq()
Sets up the main zmq context and the sockets which are accessed within this process.
        This needs to be called within the run-method
Sets up the main zmq context and the sockets which are accessed within this process.
This needs to be called within the run-method
Sets up the main zmq context and the sockets which are accessed within this process . This needs to be called within the run - method
def _setup_interpreter(self):
        self.context = zmq.Context()
        self.data_pub = self.context.socket(zmq.PUB)
        self.data_pub.set_hwm(10)  
        self.data_pub.bind(self._tcp_addr(self.setup['port']['data']))
        self._setup_logging()
        self._setup_daq()
def _setup_interpreter ( self ) : self . context = zmq . Context ( ) self . data_pub = self . context . socket ( zmq . PUB ) self . data_pub . set_hwm ( 10 ) self . data_pub . bind ( self . _tcp_addr ( self . setup [ 'port' ] [ 'data' ] ) ) self . _setup_logging ( ) self . _setup_daq ( )
Sets up the main zmq context and the sockets which are accessed within this process.
Sets up the main zmq context and the sockets which are accessed within this process .
"""Sets up the main zmq context and the sockets which are accessed within this process.
        This needs to be called within the run-method""" # Create main context for this process; sockets need to be created on their respective threads! # Create PUB socket in order to send interpreted data # drop data if too slow # Start logging # Start daq
self