proxyTransportLayer.py 文件源码

def __init__(self,logFile,IPCLayer,NetworkServiceLayer) :
        threading.Thread.__init__(self)

        self.threadCmdLock = threading.Lock()
        self.threadCmdQueue = []
        self.threadCallbackQueue = {}
        self.threadCallbackLock = threading.Lock()

        self.log = logger.Logger(logFile,"core Transport Layer Thread")
        self.IPCLayer = IPCLayer
        self.NetServiceLayer = NetworkServiceLayer
        self.nPendingCallbacks = 0
        self.sendSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)