ListCommunication.py 文件源码

def __init__(self, addr="*", port="8080", logger=None):
        self.logger = logger
        # create a socket object
        self.context = zmq.Context()
        self.complete_address = Address(addr, port).complete_address
        self.sync_address = ''
        # Socket used with the following node
        self.list_communication_channel = None

        # This part is just for test
        # if port == '5555':
        #     self.sync_address = Address(addr, '5562').complete_address
        # elif port == '5556':
        #     self.sync_address = Address(addr, '5563').complete_address
        # elif port == '5557':
        #     self.sync_address = Address(addr, '5564').complete_address