hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] fix serialize gi input core

Browse Source
This commit is contained in:
sdc
2024-04-07 07:30:14 +00:00
committed by ob-robot
parent cac0a7d1e6
commit 6bb613e0d5
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/px/ob_granule_iterator_op.cpp
View File

@ -94,10 +94,15 @@ OB_DEF_SERIALIZE(ObGIOpInput)
BASE_SER(ObGIOpInput); BASE_SER(ObGIOpInput);
LST_DO_CODE(OB_UNIS_ENCODE, parallelism_, worker_id_); LST_DO_CODE(OB_UNIS_ENCODE, parallelism_, worker_id_);
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_UNLIKELY(pos + sizeof(pump_) > buf_len)) {
ret = OB_SIZE_OVERFLOW;
LOG_WARN("size overflow", K(pos), K(buf_len));
} else {
MEMCPY(buf + pos, &pump_, sizeof(pump_)); MEMCPY(buf + pos, &pump_, sizeof(pump_));
pos += sizeof(pump_); pos += sizeof(pump_);
//LOG_TRACE("muhang(pump)SE", K(pump_)); //LOG_TRACE("muhang(pump)SE", K(pump_));
} }
}
OB_UNIS_ENCODE(table_location_keys_); OB_UNIS_ENCODE(table_location_keys_);
return ret; return ret;
} }
@ -109,7 +114,6 @@ OB_DEF_DESERIALIZE(ObGIOpInput)
BASE_DESER(ObGIOpInput); BASE_DESER(ObGIOpInput);
LST_DO_CODE(OB_UNIS_DECODE, parallelism_, worker_id_); LST_DO_CODE(OB_UNIS_DECODE, parallelism_, worker_id_);
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
int64_t count = 0;
const char *str = buf + pos;; const char *str = buf + pos;;
MEMCPY(&pump_, str, sizeof(pump_)); MEMCPY(&pump_, str, sizeof(pump_));
pos = pos + sizeof(pump_); pos = pos + sizeof(pump_);