auth_master.py 文件源码

def __init__(self,server,port,secret,requests,concurrency,username,password,
        verb=False,timeout=30,forknum=1,interval=2,rate=1000):
        self.interval = interval
        tparams = [
            ' - Client platform                   :  %s, %s'% (platform.platform(),platform.machine()),
            ' - Python implement, version         :  %s, %s'% (platform.python_implementation(), platform.python_version()),
            ' - Radius server  address            :  %s'% server,
            ' - Radius Server auth port           :  %s'% port,
            ' - Raduius share secret              :  %s'% secret,
            ' - Auth Request total                :  %s'% requests,
            ' - Concurrency level                 :  %s'% concurrency,
            ' - Worker Process num                :  %s'% forknum,
            ' - All Requests timeout              :  %s sec'% timeout,
            ' - Stat data interval                :  %s sec'% interval,
            ' - Send request rate                 :  %s/sec'% rate,
        ]
        self.stat_counter = AuthStatCounter(tparams)
        self.puller = ZmqPullConnection(ZmqFactory(), ZmqEndpoint('bind', 'ipc:///tmp/toughbt-message'))
        self.puller.onPull = self.do_stat
        # log.msg("init BenchmarkMaster puller : %s " % (self.puller))

        reactor.callLater(interval,self.chk_task)
        reactor.callLater(timeout,reactor.stop)