test/dataflow
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

改进

Browse Source
This commit is contained in:
eson 2022-06-08 18:08:33 +08:00
parent bbf4a47ed3
commit bde4b7985d
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/yuandian/dataflow/master/Header.java
View File

@ -47,5 +47,18 @@ public class Header {
log.error("{}", pheader); log.error("{}", pheader);
log.error("{}",PacketBase.createPacketBase(pheader)); log.error("{}",PacketBase.createPacketBase(pheader));
//60010流需要解压
byte[] unzipbodydata = null;
if (pheader.getTableID() == 20) {
pheader.parseNextHeader_60010(in);
byte[] zipbodydata = new byte[packetHeader.getMsg_len()];
readTillLength(zipbodydata, packetHeader.getMsg_len());
unzipbodydata = ZlibUtil.Inflate(zipbodydata);
}
} }
} }

3
src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
View File

@ -30,9 +30,6 @@ public class BacktrackingFlow extends PacketBase{
private long mplsLabel;// 4 private long mplsLabel;// 4
@Override @Override
public PacketBase Parse(PacketHeader header,ByteBuffer data) throws Exception { public PacketBase Parse(PacketHeader header,ByteBuffer data) throws Exception {
BacktrackingFlow backFlow = new BacktrackingFlow(); BacktrackingFlow backFlow = new BacktrackingFlow();