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-26 18:13:08 +08:00
parent 271f6d1e03
commit a3e660ff63
1 changed files with 36 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
src/main/java/org/redkale/convert/pb/ProtobufReader.java
View File

@@ -512,75 +512,77 @@ public class ProtobufReader extends Reader {
} }
protected int readRawVarint32() { // readUInt32 protected int readRawVarint32() { // readUInt32
byte[] data = content;
fastpath: fastpath:
{ {
int tempPos = this.position; int curr = this.position;
if ((tempPos + 1) == content.length) { if ((curr + 1) == data.length) {
break fastpath; break fastpath;
} }
int x; int x;
if ((x = content[++tempPos]) >= 0) { if ((x = data[++curr]) >= 0) {
this.position = tempPos; this.position = curr;
return x; return x;
} else if (content.length - (tempPos + 1) < 9) { } else if (data.length - (curr + 1) < 9) {
break fastpath; break fastpath;
} else if ((x ^= (content[++tempPos] << 7)) < 0) { } else if ((x ^= (data[++curr] << 7)) < 0) {
x ^= (~0 << 7); x ^= (~0 << 7);
} else if ((x ^= (content[++tempPos] << 14)) >= 0) { } else if ((x ^= (data[++curr] << 14)) >= 0) {
x ^= (~0 << 7) ^ (~0 << 14); x ^= (~0 << 7) ^ (~0 << 14);
} else if ((x ^= (content[++tempPos] << 21)) < 0) { } else if ((x ^= (data[++curr] << 21)) < 0) {
x ^= (~0 << 7) ^ (~0 << 14) ^ (~0 << 21); x ^= (~0 << 7) ^ (~0 << 14) ^ (~0 << 21);
} else { } else {
int y = content[++tempPos]; int y = data[++curr];
x ^= y << 28; x ^= y << 28;
x ^= (~0 << 7) ^ (~0 << 14) ^ (~0 << 21) ^ (~0 << 28); x ^= (~0 << 7) ^ (~0 << 14) ^ (~0 << 21) ^ (~0 << 28);
if (y < 0 if (y < 0
&& content[++tempPos] < 0 && data[++curr] < 0
&& content[++tempPos] < 0 && data[++curr] < 0
&& content[++tempPos] < 0 && data[++curr] < 0
&& content[++tempPos] < 0 && data[++curr] < 0
&& content[++tempPos] < 0) { && data[++curr] < 0) {
break fastpath; // Will throw malformedVarint() break fastpath; // Will throw malformedVarint()
} }
} }
this.position = tempPos; this.position = curr;
return x; return x;
} }
return (int) readRawVarint64SlowPath(); return (int) readRawVarint64SlowPath();
} }
protected long readRawVarint64() { protected long readRawVarint64() {
byte[] data = content;
fastpath: fastpath:
{ {
int tempPos = this.position; int curr = this.position;
if ((tempPos + 1) == content.length) { if ((curr + 1) == data.length) {
break fastpath; break fastpath;
} }
long x; long x;
int y; int y;
if ((y = content[++tempPos]) >= 0) { if ((y = data[++curr]) >= 0) {
this.position = tempPos; this.position = curr;
return y; return y;
} else if (content.length - (tempPos + 1) < 9) { } else if (data.length - (curr + 1) < 9) {
break fastpath; break fastpath;
} else if ((y ^= (content[++tempPos] << 7)) < 0) { } else if ((y ^= (data[++curr] << 7)) < 0) {
x = y ^ (~0 << 7); x = y ^ (~0 << 7);
} else if ((y ^= (content[++tempPos] << 14)) >= 0) { } else if ((y ^= (data[++curr] << 14)) >= 0) {
x = y ^ ((~0 << 7) ^ (~0 << 14)); x = y ^ ((~0 << 7) ^ (~0 << 14));
} else if ((y ^= (content[++tempPos] << 21)) < 0) { } else if ((y ^= (data[++curr] << 21)) < 0) {
x = y ^ ((~0 << 7) ^ (~0 << 14) ^ (~0 << 21)); x = y ^ ((~0 << 7) ^ (~0 << 14) ^ (~0 << 21));
} else if ((x = y ^ ((long) content[++tempPos] << 28)) >= 0L) { } else if ((x = y ^ ((long) data[++curr] << 28)) >= 0L) {
x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28); x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28);
} else if ((x ^= ((long) content[++tempPos] << 35)) < 0L) { } else if ((x ^= ((long) data[++curr] << 35)) < 0L) {
x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35); x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35);
} else if ((x ^= ((long) content[++tempPos] << 42)) >= 0L) { } else if ((x ^= ((long) data[++curr] << 42)) >= 0L) {
x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35) ^ (~0L << 42); x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35) ^ (~0L << 42);
} else if ((x ^= ((long) content[++tempPos] << 49)) < 0L) { } else if ((x ^= ((long) data[++curr] << 49)) < 0L) {
x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35) ^ (~0L << 42) ^ (~0L << 49); x ^= (~0L << 7) ^ (~0L << 14) ^ (~0L << 21) ^ (~0L << 28) ^ (~0L << 35) ^ (~0L << 42) ^ (~0L << 49);
} else { } else {
x ^= ((long) content[++tempPos] << 56); x ^= ((long) data[++curr] << 56);
x ^= (~0L << 7) x ^= (~0L << 7)
^ (~0L << 14) ^ (~0L << 14)
^ (~0L << 21) ^ (~0L << 21)
@@ -590,12 +592,12 @@ public class ProtobufReader extends Reader {
^ (~0L << 49) ^ (~0L << 49)
^ (~0L << 56); ^ (~0L << 56);
if (x < 0L) { if (x < 0L) {
if (content[++tempPos] < 0L) { if (data[++curr] < 0L) {
break fastpath; // Will throw malformedVarint() break fastpath; // Will throw malformedVarint()
} }
} }
} }
this.position = tempPos; this.position = curr;
return x; return x;
} }
return readRawVarint64SlowPath(); return readRawVarint64SlowPath();
@@ -603,10 +605,13 @@ public class ProtobufReader extends Reader {
protected long readRawVarint64SlowPath() { protected long readRawVarint64SlowPath() {
long result = 0; long result = 0;
byte[] data = content;
int curr = this.position;
for (int shift = 0; shift < 64; shift += 7) { for (int shift = 0; shift < 64; shift += 7) {
final byte b = content[++this.position]; final byte b = data[++curr];
result |= (long) (b & 0x7F) << shift; result |= (long) (b & 0x7F) << shift;
if ((b & 0x80) == 0) { if ((b & 0x80) == 0) {
this.position = curr;
return result; return result;
} }
} }