lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

protobuf

Browse Source
This commit is contained in:
redkale
2024-09-25 15:30:27 +08:00
parent a42e3cd63c
commit cf638997f6
2 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/redkale/convert/pb/ProtobufConvert.java
View File

@@ -685,13 +685,13 @@ public class ProtobufConvert extends BinaryConvert<ProtobufReader, ProtobufWrite
if (encoder == null || encoder.getType() != t) { if (encoder == null || encoder.getType() != t) {
encoder = factory.loadEncoder(t); encoder = factory.loadEncoder(t);
this.lastEncodeable = encoder; this.lastEncodeable = encoder;
if (!(encoder instanceof ObjectEncoder) && !(encoder instanceof SimpledCoder)) {
throw new ConvertException(this.getClass().getSimpleName() + " not supported type(" + t + ")");
}
} }
if (encoder.specifyable()) { if (encoder.specifyable()) {
writer.specificObjectType(t); writer.specificObjectType(t);
} }
if (!(encoder instanceof ObjectEncoder) && !(encoder instanceof SimpledCoder)) {
throw new ConvertException(this.getClass().getSimpleName() + " not supported type(" + t + ")");
}
encoder.convertTo(writer, value); encoder.convertTo(writer, value);
byte[] result = writer.toArray(); byte[] result = writer.toArray();
offerWriter(writer); offerWriter(writer);

9
src/main/java/org/redkale/convert/pb/ProtobufWriter.java
View File

@@ -207,12 +207,9 @@ public class ProtobufWriter extends Writer implements ByteTuple {
@Override @Override
public byte[] toArray() { public byte[] toArray() {
if (count == content.length) { byte[] copy = new byte[count];
return content; System.arraycopy(content, 0, copy, 0, count);
} return copy;
byte[] newdata = new byte[count];
System.arraycopy(content, 0, newdata, 0, count);
return newdata;
} }
public ProtobufWriter enumtostring(boolean enumtostring) { public ProtobufWriter enumtostring(boolean enumtostring) {