proxyIPCLayer.py 文件源码

def __init__(self, logFile, hostIDList):
        threading.Thread.__init__(self)

        self.threadCmdLock = threading.Lock()
        self.threadCmdQueue = []

        self.threadCallbackQueue = {}
        self.threadCallbackLock = threading.Lock()

        self.sharedBufferArray = shared_buffer_array()
        self.log = logger.Logger(logFile, "core IPC Thread")
        self.hostList = hostIDList
        self.nPendingCallbacks = 0
        self.controlCenterID = -1
        self.hostIDtoPowerSimID = None
        self.powerSimIDtohostID = None
        self.transportLayer = None
        self.nHosts = len(self.hostList)
        self.init_shared_ipc_buffers()