From 9ef652b092427bcfb306fa5d90fab1eeebe974bc Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期五, 08 十二月 2023 08:39:13 +0800
Subject: [PATCH] 删除临时文件
---
pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java | 19 +++++++++++++++++++
1 files changed, 19 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java
index 8e057db..cf45570 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java
@@ -82,6 +82,8 @@
doDealReportCount(rqVo) ;
}else if(rqVo.code.equals(Code.cd5)){
doDealReportOver(rqVo) ;
+ }else if(rqVo.code.equals(Code.cd6)){
+ doDealAllOver(rqVo) ;
}
return resVo ;
}
@@ -114,6 +116,8 @@
conVo.rtuAddrEnd = (Long)rtuAddrs[1] ;
conVo.tcpServerIp = ServerProperties.tcpServerIp ;
conVo.tcpServerPort = ServerProperties.tcpServerPort ;
+ conVo.sendInterval = ServerProperties.sendInterval ;
+ conVo.heartbeatTimes = ServerProperties.heartbeatTimes ;
conVo.sendTimes = ServerProperties.sendTimes ;
sta = new MwTestClientStatus() ;
sta.confVo = conVo ;
@@ -157,6 +161,19 @@
MwTestClientStatus sta = token2ClientMap.get("" + token);
if(sta == null){
sta = new MwTestClientStatus() ;
+ sta.overCount = rqVo.overCount ;
+ token2ClientMap.put("" + token, sta);
+ }else{
+ sta.overCount = rqVo.overCount ;
+ }
+ }
+
+
+ private static void doDealAllOver(RmiRequestVo rqVo){
+ int token = Integer.parseInt(rqVo.token) ;
+ MwTestClientStatus sta = token2ClientMap.get("" + token);
+ if(sta == null){
+ sta = new MwTestClientStatus() ;
if(rqVo.over != null && rqVo.over){
sta.over = true ;
sta.seconds = rqVo.seconds ;
@@ -170,4 +187,6 @@
}
}
+
+
}
--
Gitblit v1.8.0