Commit 11a031a4 authored by liyuanhong's avatar liyuanhong

修改了新硬件压测程序随机数多出一位的bug

parent 7c5aabee
...@@ -20,12 +20,12 @@ class SendMultMsgNewThread(ThreadBase): ...@@ -20,12 +20,12 @@ class SendMultMsgNewThread(ThreadBase):
self.msg = msg self.msg = msg
self.timeOut = 30 #socket超时时间 self.timeOut = 30 #socket超时时间
self.BUF_SIZE = 1024 #接收消息缓存 self.BUF_SIZE = 1024 #接收消息缓存
self.threadCount = 1000 #并发线程数 self.threadCount = 10 #并发线程数
self.totalTime = 0 #所有线程的运行总和 self.totalTime = 0 #所有线程的运行总和
self.threadArr = {} #保存每个线程的信息 self.threadArr = {} #保存每个线程的信息
self.failThreadCount = 0 #失败线程数 self.failThreadCount = 0 #失败线程数
self.durThreads = [] #持续发送线程数组,当数组为空,表示所有线程已经结束 self.durThreads = [] #持续发送线程数组,当数组为空,表示所有线程已经结束
dt = 1 * 10 * 60 dt = 1 * 1 * 60
self.durTime = dt #线程持续时间 self.durTime = dt #线程持续时间
self.connectTimeoutNum = 0 #连接超时线程数 self.connectTimeoutNum = 0 #连接超时线程数
self.sendTimeoutNum = 0 #发送超时线程数 self.sendTimeoutNum = 0 #发送超时线程数
...@@ -293,7 +293,7 @@ class SendMultMsgNewThread(ThreadBase): ...@@ -293,7 +293,7 @@ class SendMultMsgNewThread(ThreadBase):
# 获取随机消息数据(新硬件车机) # 获取随机消息数据(新硬件车机)
def getRandomMsg_new(self, carId): def getRandomMsg_new(self, carId):
# carId = 201912010002 # carId = 201912010002
wh = random.randint(0,5) wh = random.randint(0,4)
msg = "" msg = ""
if wh == 0: if wh == 0:
hearbeatObj = TerminalHeartbeat_msg() hearbeatObj = TerminalHeartbeat_msg()
......
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