1、增加断点续传统计
2、增加消息按类型查询
This commit is contained in:
parent
cbcd894275
commit
29824f4743
@ -117,12 +117,13 @@ public class SaasForwarder extends Forwarder{
|
|||||||
|
|
||||||
boolean checkResult() throws InterruptedException {
|
boolean checkResult() throws InterruptedException {
|
||||||
// 等待应答,最多等1s
|
// 等待应答,最多等1s
|
||||||
for(int i=0; i<10; i++){
|
/*for(int i=0; i<10; i++){
|
||||||
Thread.sleep(100);
|
Thread.sleep(100);
|
||||||
if(listener.state == MyTCPListener.STATE_OK) return true;
|
if(listener.state == MyTCPListener.STATE_OK) return true;
|
||||||
else if(listener.state == MyTCPListener.STATE_FAILED) return false;
|
else if(listener.state == MyTCPListener.STATE_FAILED) return false;
|
||||||
}
|
}*/
|
||||||
return false;
|
Thread.sleep(100);
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -139,6 +139,6 @@ public class DataPersistServiceImpl implements DataPersistService {
|
|||||||
public void saveD342Stat(D342LocationMessage message, Device device){
|
public void saveD342Stat(D342LocationMessage message, Device device){
|
||||||
saveMsg(message, "d342 num:"+device.getD342Count()+
|
saveMsg(message, "d342 num:"+device.getD342Count()+
|
||||||
", bytes:"+device.getD342Bytes()+
|
", bytes:"+device.getD342Bytes()+
|
||||||
", total d341 num:"+device.getD341In42Count()+"session done");
|
", total d341 num:"+device.getD341In42Count()+", session done");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user