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-10-02 00:50:40 +08:00
parent 692f0fa8b1
commit 4e71f8009a
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -130,14 +130,13 @@ public class ProtobufWriter extends Writer implements ByteTuple {
protected boolean recycle() { protected boolean recycle() {
super.recycle(); super.recycle();
if (this.delegate != null && this.pool != null) { if (this.delegate != null && this.pool != null) {
List<ProtobufWriter> list = new ArrayList<>(); ProtobufWriter s;
ProtobufWriter next = this; ProtobufWriter p = this.delegate;
while ((next = next.child) != null) { do {
list.add(next); s = p;
} p = p.parent;
for (ProtobufWriter item : list) { offerPool(s);
offerPool(item); } while (p != this);
}
} }
this.parent = null; this.parent = null;
this.child = null; this.child = null;
@@ -169,7 +168,7 @@ public class ProtobufWriter extends Writer implements ByteTuple {
} }
ProtobufWriter result = queue.poll(); ProtobufWriter result = queue.poll();
if (result == null) { if (result == null) {
result = new ProtobufWriter(); result = new ProtobufWriter(new byte[256], 0);
} }
if (delegate == null) { if (delegate == null) {
result.parent = this; result.parent = this;