def __init__(self, masterip, port):
        # create socket for sending tcms xmlrpc signal
        self.caserun = {}
        self.context = zmq.Context.instance()
        self.results_sender = self.context.socket(zmq.PUSH)
        self.sport = str(int(port) + 1)
        self.results_sender.connect("tcp://%s:%s" % (masterip, self.sport))
dataset/ETHPy150Open idumpling/robotx/robotx/core/distlistener.py/MultiListener.__init__/original