File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
src/main/java/com/alipay/oceanbase/rpc/table Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -160,8 +160,15 @@ public Object decode(ByteBuf buf) {
160160 }
161161
162162 public long getPayloadContentSize () {
163- return 1 + Serialization .getNeedBytes (caching ) + Serialization .getNeedBytes (callTimeout )
164- + 1 ; // all boolean to one byte
163+ long contentSize = 1 + Serialization .getNeedBytes (caching ) + Serialization .getNeedBytes (callTimeout )
164+ + 1 // all boolean to one byte
165+ + Serialization .getNeedBytes (timeRangeMap .size ());
166+ for (ObPair <ObBytesString , ObPair <Long , Long >> timeRange : timeRangeMap ) {
167+ contentSize += Serialization .getNeedBytes (timeRange .getLeft ());
168+ contentSize += Serialization .getNeedBytes (timeRange .getRight ().getLeft ());
169+ contentSize += Serialization .getNeedBytes (timeRange .getRight ().getRight ());
170+ }
171+ return contentSize ;
165172 }
166173
167174 public String toString () {
You can’t perform that action at this time.
0 commit comments