runTest.py 文件源码

def runWithAccident():
    print "***ready to test with event"
    for (ip,name) in nodes:
        accidentJoin(ip)
        time.sleep(2)
    print "****all nodes restarted"
    #time.sleep(10)
    #print "****wait for key"
    #raw_input()

    interval=event_interval
    try:
        if(options.recur):
            simulateThread=threading.Thread(target=recurEventThread, args=(interval,test_time,))
        else:
            simulateThread=threading.Thread(target=simulateAccidentThread, 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:
        exit(-1)