From 9495bcfcdbbf2d1ae6ec2a7697dadea31abb3b33 Mon Sep 17 00:00:00 2001 From: fengyarnom Date: Wed, 30 Oct 2024 18:11:08 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E6=B6=88=E6=81=AF=E8=A7=A3?= =?UTF-8?q?=E7=A0=81=E6=97=B6=EF=BC=8C=E6=9C=AA=E5=B0=86=E5=8E=9F=E7=A0=81?= =?UTF-8?q?=E4=BF=9D=E5=AD=98=E8=87=B3=20srcData=20=E7=9A=84=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/imdroid/sideslope/message/D3F0SelfCheckMessage.java | 5 +++++ .../sideslope/message/D3F2StopIndicationMessage.java | 6 ++++++ 2 files changed, 11 insertions(+) diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F0SelfCheckMessage.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F0SelfCheckMessage.java index e4080df6..bfb51351 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F0SelfCheckMessage.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F0SelfCheckMessage.java @@ -58,6 +58,11 @@ public class D3F0SelfCheckMessage extends BaseMessage { " reboot:"+src.readUnsignedShort(); } + // read 会移动 bytebuf 的指针，所以保存原始码流需要将此指针挑拨回开始处 + src.readerIndex(0); + this.srcData = new byte[src.readableBytes()]; + src.readBytes(this.srcData); + } } diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F2StopIndicationMessage.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F2StopIndicationMessage.java index fe29825d..5a5336da 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F2StopIndicationMessage.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/message/D3F2StopIndicationMessage.java @@ -1,5 +1,6 @@ package com.imdroid.sideslope.message; +import com.imdroid.common.util.HexUtil; import com.imdroid.secapi.dto.GnssTrxMsg; import io.netty.buffer.ByteBuf; import lombok.Data; @@ -60,6 +61,11 @@ public class D3F2StopIndicationMessage extends BaseMessage { } } + + // read 会移动 bytebuf 的指针，所以保存原始码流需要将此指针挑拨回开始处 + src.readerIndex(0); + this.srcData = new byte[src.readableBytes()]; + src.readBytes(this.srcData); } }