network.py 文件源码

def onSkeyAvailable(self, request=None ):
        """
            New SKey got avaiable
        """
        self.isRequesting = False
        try:
            skey = NetworkService.decode( request )
        except:
            SecurityTokenProvider.errorCount += 1
            self.isRequesting = False
            return
        if SecurityTokenProvider.errorCount>0:
            SecurityTokenProvider.errorCount = 0
        self.isRequesting = False
        if not skey:
            return
        try:
            self.queue.put( (skey,time.time()), False )
        except QFull:
            print( "Err: Queue FULL" )