调整压测

zhouhaihai
1 parent 1be37174
Showing 7 changed files with 25 additions and 22 deletions Show diff stats
robot/robot.lua
robot/start.lua
robot/unitTest/hero.lua
src/actions/HangAction.lua
src/actions/RoleAction.lua
src/models/RolePlugin.lua
src/services/redisd.lua
@@ -34,6 +34,9 @@ local ignoreListener = {
 	["Role.changeUpdate"] = true,
 	["Role.loadRunes"] = true,
 	["Hero.loadInfos"] = true,
+	["Store.updateproperty"] = true,
+	["Sys.maintainNotice"] = true,
+	["Hero.drawHeroExtraRewardNtf"] = true,
 	["Sys.innerErrorMsg"] = function(data)
 		local msg = MsgPack.unpack(data)
 		log("innerErrorMsg: " .. msg.id)
@@ -123,11 +126,6 @@ local function startUnit(unit)
 	unitTest.new(client):startTest()
 end
  
-local function handle_timeout10000()
-	rpcServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 1, pm2 = 500}))
-	rpcServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 2, pm2 = 500}))
-	skynet.timeout(10000, handle_timeout6000)
-end
  
 -- 登录成功开始任务
 function CMD.task()
@@ -155,6 +153,9 @@ end
  
 -- 退出
 function CMD.exit()
+	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "gmmsg", pm1 = "123"}))
+	skynet.sleep(50)
+	skynet.ret(skynet.pack())
 	skynet.exit()
 end
  
@@ -19,9 +19,9 @@ function MSG.open( ... )
 end
  
 function MSG.close(fd)
-	if fd2serv[fd] then
-		skynet.send(fd2serv[fd].agent, "lua", "exit")
-
+	if fd2serv[fd] and not fd2serv[fd].closing then
+		fd2serv[fd].closing = true
+		skynet.call(fd2serv[fd].agent, "lua", "exit")
 		log(string_format("logout %s", fd2serv[fd].id))
  
 		id2fd[fd2serv[fd].id] = nil
@@ -94,8 +94,8 @@ local function add_robot()
  
 	-- 定时下线
 	skynet.timeout(math.randomInt(config.online_time[1], config.online_time[2]) * 100, function()
-		socketdriver.close(fd)
 		MSG.close(fd)
+		socketdriver.close(fd)
 	end)
 end
  
@@ -26,7 +26,7 @@ end
  
 function _M:drawHero()
 	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 3, pm2 = 400}))
-	requestServer(actionCodes.Hero_drawHeroRpc, MsgPack.pack({pool = 1, type = 1}))
+	requestServer(actionCodes.Hero_drawHeroRpc, MsgPack.pack({pool = 2, type = 1}))
 end
  
 function _M:drawHero10()
@@ -278,7 +278,6 @@ function _M.endBattleRpc(agent, data)
 		local cfg = csvdb["idle_battleCsv"][nextCarbonId]
 		if cfg then
 			hangInfo.bossTime = skynet.timex() + cfg.idle_time
-			print(hangInfo.bossTime)
 		end
 	end
 	role:updateProperty({field = "hangInfo", value = hangInfo})
@@ -977,7 +977,7 @@ function _M.chatRpc(agent, data)
 	role:log("communication", {
 		publish_type = cmd, --发言类型，1，世界  2私聊 
 		publish_status = 0, --发送状态，发送成功:0，发送失败:1，被屏蔽:2，其他:3
-		publish_receive_roleid = msg.roleId, --接收者角色ID
+		publish_receive_roleid = msg.roleId or 0, --接收者角色ID
 		publish_text = content, --发言内容
 	})
 	SendPacket(actionCodes.Role_chatRpc, MsgPack.pack({result = result, waitTime = waitTime}))
@@ -238,7 +238,7 @@ function RolePlugin.bind(Role)
 		end
  
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] then
 				print("addPlayExp error log have cint1 or cint2  or cint3", debug.traceback())
 			end
@@ -275,7 +275,7 @@ function RolePlugin.bind(Role)
  
 		self:logItems(params.itemId, origin, nums, params.log)
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] then
 				print("addItem error log have cint1 or cint2  ", debug.traceback())
 			end
@@ -299,7 +299,7 @@ function RolePlugin.bind(Role)
 	function Role:checkItemEnough(itemCountT)
 		local less = {}
 		if not next(itemCountT) then
-			return false, less
+			return true, less
 		end
 		for itemId, count in pairs(itemCountT) do
 			if count <= 0 then
@@ -360,7 +360,7 @@ function RolePlugin.bind(Role)
  
 		self:logItems(ItemId.Diamond, origin, count, params.log)
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] or log["cint3"] then
 				print("costDiamond error log have cint1 or cint2 or cint3 ", debug.traceback())
 			end
@@ -410,7 +410,7 @@ function RolePlugin.bind(Role)
  
 		self:logItems(ItemId.Diamond, origin, count, params.log)
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] or log["cint3"] then
 				print("costDiamond error log have cint1 or cint2 or cint3 ", debug.traceback())
 			end
@@ -459,7 +459,7 @@ function RolePlugin.bind(Role)
 		self:logItems(heroType + ItemStartId.Hero, 0, 1, params.log)
  
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] or log["cint3"] then
 				print("addHero error log have cint1 or cint2 or cint3 ", debug.traceback())
 			end
@@ -580,7 +580,7 @@ function RolePlugin.bind(Role)
  
 		self:logItems(equipCsv.id, oldCount, curCount, pms.log)
 		if pms.log then
-			local log = pms.log
+			local log = clone(pms.log)
 			if log["cint1"] or log["cint2"] or log["cint3"] then
 				print("addEquip error log have cint1 or cint2 or cint3 ", debug.traceback())
 			end
@@ -656,7 +656,7 @@ function RolePlugin.bind(Role)
  
 			self:logItems(params.id, 0, 1, params.log)
 			if params.log then
-				local log = params.log
+				local log = clone(params.log)
 				if log["cint1"] or log["cint2"] or log["cint3"] then
 					print("addRune error log have cint1 or cint2 or cint3 ", debug.traceback())
 				end
@@ -686,7 +686,7 @@ function RolePlugin.bind(Role)
  
 				self:logItems(rune:getProperty("id"), 1, 0, params.log)
 				if params.log then
-					local log = params.log
+					local log = clone(params.log)
 					if log["cint1"] or log["cint2"] or log["cint3"] then
 						print("delRunes error log have cint1 or cint2 or cint3 ", debug.traceback())
 					end
@@ -946,7 +946,7 @@ function RolePlugin.bind(Role)
  
 		self:logItems(func, 0, count, params.log)
 		if params.log then
-			local log = params.log
+			local log = clone(params.log)
 			if log["cint1"] or log["cint2"] or log["cint3"] then
 				print("funcOpen error log have cint1 or cint2 or cint3 ", debug.traceback())
 			end
@@ -24,5 +24,8 @@ skynet.start(function()
 			skynet.ret(skynet.pack(db[string.lower(cmd)](db, ...)))
 		end
 	end)
+	skynet.info_func(function()
+		skynet.ret(skynet.pack(skynet.call(skynet.self(), "debug", "STAT")))
+	end)
 	skynet.register ".redis"
 end)
 \ No newline at end of file