Skip to content

Commit 1ab5dfa

Browse files
committed
opt header serialize
1 parent b5d0f42 commit 1ab5dfa

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/main/java/com/alipay/oceanbase/rpc/util/Serialization.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1008,13 +1008,14 @@ public static long getObUniVersionHeaderLength(long version, long payloadLen) {
10081008
* @return output data buffer
10091009
*/
10101010
public static byte[] encodeObUniVersionHeader(long version, long payloadLen) {
1011-
byte[] bytes = new byte[(int) getObUniVersionHeaderLength(version, payloadLen)];
1011+
int versionBytes = Serialization.getNeedBytes(version);
1012+
int payloadLenBytes = Serialization.getNeedBytes(payloadLen);
1013+
byte[] bytes = new byte[versionBytes + payloadLenBytes];
10121014
int idx = 0;
1013-
1014-
int len = Serialization.getNeedBytes(version);
1015+
int len = versionBytes;
10151016
System.arraycopy(Serialization.encodeVi64(version), 0, bytes, idx, len);
1016-
idx += len;
1017-
len = Serialization.getNeedBytes(payloadLen);
1017+
idx += versionBytes;
1018+
len = payloadLenBytes;
10181019
System.arraycopy(Serialization.encodeVi64(payloadLen), 0, bytes, idx, len);
10191020

10201021
return bytes;

0 commit comments

Comments
 (0)