runTest.py 文件源码

def runWithUser():
    global GLOBAL_FLAG
    global test_time

    #reset all flag and let nodes work
    for (ip,name) in nodes:
        resetFlag(ip)

    print "***ready to test with userdefine"

    #time.sleep(10)
    #print "****wait for key"
    #raw_input()

    interval=event_interval
    try:
    #if(1):
        #simulateUserThread(interval,test_time)
        #exit(0)

        if(options.recur):
            simulateThread=threading.Thread(target=recurUserThread, args=(interval,test_time,))
        else:
            simulateThread=threading.Thread(target=simulateUserThread, args=(interval,test_time,))

        #simulateThread=threading.Thread(target=simulateAccidentThread,args=(interval,test_time))
        #simulateThread.start()
        simulateThread.setDaemon(True)
        simulateThread.start()
        runTest()
        GLOBAL_FLAG=False
        print "****global flag:",GLOBAL_FLAG
        simulateThread.join()

    except KeyboardInterrupt:
        for (ip,name) in nodes:
            resetFlag(ip)
        exit(-1)
        return