wefree/min-dev-java
1
0
Fork 0
mirror of https://gitee.com/willfree/min-dev-java.git synced 2026-06-17 23:00:24 +08:00
Code Issues Projects Releases Wiki Activity

supplement StreamTransport.doReceive()

Browse Source
This commit is contained in:
free will
2021-04-21 18:36:39 +08:00
parent 13c954e247
commit 09c820f264
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/logicface/StreamTransport.java
+3 -1
View File
@@ -128,7 +128,9 @@ public class StreamTransport extends Transport implements ITransport{
LpPacket lpPacket=packetPair.getValue();
// 循环多次尝试从接收缓冲区中读出包并处理
if(pktLen>0){
//todo: 啥玩意儿？？？
System.arraycopy(this.recvBuf,(int)pktLen,
this.recvBuf,0,(int)(this.recvLen-pktLen));
this.recvLen-=pktLen;
}
return lpPacket;
}
src/main/java/logicface/UnixStreamTransport.java
+3 -1
View File
@@ -141,7 +141,9 @@ public class UnixStreamTransport extends StreamTransport{
LpPacket lpPacket=packetPair.getValue();
// 循环多次尝试从接收缓冲区中读出包并处理
if(pktLen>0){
//todo: 啥玩意儿？？？
System.arraycopy(this.recvBuf,(int)pktLen,
this.recvBuf,0,(int)(this.recvLen-pktLen));
this.recvLen-=pktLen;
}
return lpPacket;
}