更新了压力测试脚本重复连接的问题

run.py

@@ -31,10 +31,10 @@ def getPressTestObj():
     test = FlvPressureTest()
     test.setHost("10.100.11.125")
     test.setPort(1078)
-    test.setMobileStart(10000000000)                  # 开始的设备号 （累加）
+    test.setMobileStart(50000000000)                  # 开始的设备号 （累加）
     test.setChannel(1)                                # 设置频道号
-    test.setTerNum(10)                                 # 要启动的推拉流线程
-    test.setIsOpenPullStream(1)                       # 设置是否开启拉流
+    test.setTerNum(30)                                 # 要启动的推拉流线程
+    test.setIsOpenPullStream(0)                       # 设置是否开启拉流
     test.setIsShowFrame(0)                            # 拉流是否显示预览画面     （压力测试都应该填：0）
     test.setSendDur(0.007)                            # 设置socket 发送数据间隔
     test.setFlvPath("flv/aaa3.flv")                   # 设置视频路劲
@@ -45,7 +45,7 @@ def getPressTestObj():
 #       推流flv文件压力测试
 ###########################################
 def flvFilePushTest():
-    isLoop = 1                                         # 是否循环压力测试  0： 不循环  1：循环
+    isLoop = 0                                         # 是否循环压力测试  0： 不循环  1：循环
     loopTime = 1 * 60 * 60                             # 循环压力测试的时长
     test = getPressTestObj()
     logger.info("-----------------------------启动新一轮压力测试-----------------------------")
@@ -54,18 +54,20 @@ def flvFilePushTest():
     logger.info("剩余推流线程：" + str(len(threadInfo["threadObj"])))
     logger.info("剩余拉流线程：" + str(len(threadInfoPull["threadObj"])))
     if isLoop == 0:
-        while len(threadInfo["threadObj"]) != 0 and len(threadInfoPull["threadObj"]) != 0:
+        while len(threadInfo["threadObj"]) != 0 or len(threadInfoPull["threadObj"]) != 0:
             time.sleep(5)
             logger.info("剩余推流线程：" + str(len(threadInfo["threadObj"])))
             logger.info("剩余拉流线程：" + str(len(threadInfoPull["threadObj"])))
             threadInfo = test.getThreadInfo()
             threadInfoPull = test.getThreadInfoPull()
     else:
+        print(len(threadInfo["threadObj"]))
+        print(len(threadInfoPull["threadObj"]))
         if len(threadInfo["threadObj"]) == 0 and len(threadInfoPull["threadObj"]) == 0:
             test = getPressTestObj()
             threadInfo = test.getThreadInfo()
             threadInfoPull = test.getThreadInfoPull()
-        while len(threadInfo["threadObj"]) != 0 and len(threadInfoPull["threadObj"]) != 0:
+        while len(threadInfo["threadObj"]) != 0 or len(threadInfoPull["threadObj"]) != 0:
             time.sleep(5)
             logger.info("剩余推流线程：" + str(len(threadInfo["threadObj"])))
             logger.info("剩余拉流线程：" + str(len(threadInfoPull["threadObj"])))