还原

lib/testCase/FlvPressureTest.py

@@ -70,7 +70,7 @@ class FlvPressureTest():
         self.threadInfo["threadObj"].pop(threadName)
 
 
-    '''
+
     # 使用openvc去拉流
     def testServicePull(self, mobile,threadName):
         pullUrl = self.getPlayUrl(mobile,self.channel)
@@ -93,8 +93,9 @@ class FlvPressureTest():
             self.threadInfoPull["threadObj"].pop(threadName)
             return
         self.threadInfoPull["threadObj"].pop(threadName)
-    '''
 
+
+    '''
     # 使用requests去拉流
     def testServicePull(self,mobile,threadName):
         pullUrl = self.getPlayUrl(mobile, self.channel)
@@ -106,6 +107,7 @@ class FlvPressureTest():
             self.threadInfoPull["threadObj"].pop(threadName)
             return
         self.threadInfoPull["threadObj"].pop(threadName)
+    '''
 
     ################################################
     #      启动推流线程
@@ -178,7 +180,7 @@ if __name__ == "__main__":
     test.setPort(1078)
     test.setMobileStart(10000000000)
     test.setChannel(1)
-    test.setTerNum(10)
+    test.setTerNum(50)
     test.setIsOpenPullStream(1)                            # 设置是否开启拉流
     test.setIsShowFrame(0)                                 # 拉流是否显示预览画面
     test.setSendDur(0.007)

run.py

@@ -37,7 +37,7 @@ def getPressTestObj():
     test.setMobileStart(50000000000)                  # 开始的设备号 （累加）
     test.setChannel(1)                                # 设置频道号
     test.setTerNum(30)                                 # 要启动的推拉流线程
-    test.setIsOpenPullStream(0)                       # 设置是否开启拉流
+    test.setIsOpenPullStream(1)                       # 设置是否开启拉流
     test.setIsShowFrame(0)                            # 拉流是否显示预览画面     （压力测试都应该填：0）
     test.setSendDur(0.007)                            # 设置socket 发送数据间隔
     test.setFlvPath("flv/aaa3.flv")                   # 设置视频路劲
@@ -87,7 +87,7 @@ def flvFilePushTest():
 def pullSingleSourcePressureTest():
     obj = PullStreamTest()
     obj.setPlayUrl("http://10.100.11.125:8085/live?port=1985&app=vandyo&stream=110000000000-1-336026784011127677")
-    obj.setTerNum(1)
+    obj.setTerNum(30)
     obj.start()
     pullInfos = obj.getThreadInfoPull()
     while len(pullInfos["threadObj"]) > 0:
@@ -99,6 +99,6 @@ def pullSingleSourcePressureTest():
 
 
 if __name__ == "__main__":
-    # flvFilePushTest()                            # 推拉流压力测试 （可关闭拉流）
+    flvFilePushTest()                            # 推拉流压力测试 （可关闭拉流）
     # h264FilePushTest()                           # H264推流压力测试
-    pullSingleSourcePressureTest()               # 对单个源进行拉流压力测试
+    # pullSingleSourcePressureTest()               # 对单个源进行拉流压力测试