Commit e0ce52bb authored by liyuanhong's avatar liyuanhong

设置为了循环推流

parent 803c0bff
...@@ -48,8 +48,8 @@ def getPressTestObj(): ...@@ -48,8 +48,8 @@ def getPressTestObj():
# 推流flv文件压力测试 # 推流flv文件压力测试
########################################### ###########################################
def flvFilePushTest(): def flvFilePushTest():
isLoop = 0 # 是否循环压力测试 0: 不循环 1:循环 isLoop = 1 # 是否循环压力测试 0: 不循环 1:循环
loopTime = 1 * 60 * 60 # 循环压力测试的时长 loopTime = 1 * 60 * 60 # 循环压力测试的时长(该设置现在无效)
test = getPressTestObj() test = getPressTestObj()
logger.info("-----------------------------启动新一轮压力测试-----------------------------") logger.info("-----------------------------启动新一轮压力测试-----------------------------")
threadInfo = test.getThreadInfo() threadInfo = test.getThreadInfo()
...@@ -76,7 +76,7 @@ def flvFilePushTest(): ...@@ -76,7 +76,7 @@ def flvFilePushTest():
logger.info("剩余拉流线程:" + str(len(threadInfoPull["threadObj"]))) logger.info("剩余拉流线程:" + str(len(threadInfoPull["threadObj"])))
threadInfo = test.getThreadInfo() threadInfo = test.getThreadInfo()
threadInfoPull = test.getThreadInfoPull() threadInfoPull = test.getThreadInfoPull()
time.sleep(30) time.sleep(90)
flvFilePushTest() flvFilePushTest()
logger.info("压力测试结束!!!!!!") logger.info("压力测试结束!!!!!!")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment