|
|
@@ -76,7 +76,7 @@ public class OkIoClient extends Thread{
|
|
|
if(packet.cmd == BaseMsg.RESP_REQUEST_LOGZIP){
|
|
|
LogFileMsgResp logFileMsgResp = new LogFileMsgResp();
|
|
|
logFileMsgResp.decodeData(packet.mBaseMsgBuffer, (short) packet.mBaseMsgBuffer.size());
|
|
|
- Ln.e("file size:"+logFileMsgResp.fileSize+" "+logFileMsgResp.pktNo+"/"+logFileMsgResp.pktNums+ " client zipfile "+logFileMsgResp.toString());
|
|
|
+ //Ln.e("file size:"+logFileMsgResp.fileSize+" "+logFileMsgResp.pktNo+"/"+logFileMsgResp.pktNums+ " client zipfile "+logFileMsgResp.toString());
|
|
|
DownTaskHandler downTaskHandler = peddingDownloadTasks.get(Integer.valueOf(logFileMsgResp.taskId));
|
|
|
int writtenPercent = downTaskHandler.store(logFileMsgResp.offset,logFileMsgResp.samples,logFileMsgResp.sampleSize,logFileMsgResp.pktNums,logFileMsgResp.pktNo,logFileMsgResp.fileSize);
|
|
|
logFileMsgResp.zipPath = downTaskHandler.mZipPath;//用于显示文件路径
|
|
|
@@ -88,7 +88,7 @@ public class OkIoClient extends Thread{
|
|
|
} else if(packet.cmd == BaseMsg.RESP_LOGZIP_END){
|
|
|
LogFileEndMsgResp logFileEndMsgResp = new LogFileEndMsgResp();
|
|
|
logFileEndMsgResp.decodeData(packet.mBaseMsgBuffer, (short) packet.mBaseMsgBuffer.size());
|
|
|
- Ln.e("client zipfile end----------------------------------"+logFileEndMsgResp.toString());
|
|
|
+ Ln.e("client zipfile end"/*----------------------------------"+logFileEndMsgResp.toString()*/);
|
|
|
DownTaskHandler downTaskHandler = peddingDownloadTasks.get(Integer.valueOf(logFileEndMsgResp.taskId));
|
|
|
LogFileLostMsg logFileLostMsg = (LogFileLostMsg)downTaskHandler.checkLost(Integer.valueOf(logFileEndMsgResp.taskId));
|
|
|
send(logFileLostMsg);
|
|
|
@@ -105,7 +105,7 @@ public class OkIoClient extends Thread{
|
|
|
} else if(packet.cmd == BaseMsg.REQ_HARTBEAT){
|
|
|
HartBeatMsgResp msgResp = new HartBeatMsgResp();
|
|
|
msgResp.decodeData(packet.mBaseMsgBuffer, (short) packet.mBaseMsgBuffer.size());
|
|
|
- Ln.e("client heartbeat end----------------------------------"+msgResp.toString());
|
|
|
+ Ln.e("client hb end"/*----------------------------------"+msgResp.toString()*/);
|
|
|
if(mOnOkIoMsgListener != null){
|
|
|
mOnOkIoMsgListener.onOkIoMsg(msgResp);
|
|
|
}
|
|
|
@@ -160,7 +160,7 @@ public class OkIoClient extends Thread{
|
|
|
try {
|
|
|
OkIoPacket packet = new OkIoPacket();
|
|
|
byte[] data = packet.assemblePacket(baseMsg);
|
|
|
- Ln.e("client send "+OkIoPacketDecode.toHexString(data));
|
|
|
+ Ln.e("client send "/*+OkIoPacketDecode.toHexString(data)*/);
|
|
|
mBufferedSink.write(data);
|
|
|
mBufferedSink.flush();
|
|
|
} catch (IOException e) {
|