#NEWLINE# def __init__( self , publish_port , rc_port , stats_handler , config ) : #NEWLINE# #INDENT# self . context = zmq . Context ( ) #NEWLINE# self . poller = zmq . Poller ( ) #NEWLINE# self . result_collector = self . context . socket ( zmq . PULL ) #NEWLINE# self . result_collector . bind ( 'tcp://*:{}' . format ( rc_port ) ) #NEWLINE# self . publisher = self . context . socket ( zmq . PUB ) #NEWLINE# self . publisher . bind ( 'tcp://*:{}' . format ( publish_port ) ) #NEWLINE# self . poller . register ( self . result_collector , zmq . POLLIN ) #NEWLINE# self . stats_handler = stats_handler #NEWLINE# self . config = config #NEWLINE# self . turrets = [ ] #NEWLINE# self . started = False #NEWLINE# print ( 'Warmup' ) #NEWLINE# time . sleep ( 1 )