xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix invalid read

This commit is contained in:
Yihao Deng 2024-07-07 06:04:59 +00:00
parent 3202776f0a
commit 8cbe534f93
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -2074,7 +2074,9 @@ int32_t valueEncode(void* value, int32_t vlen, int64_t ttl, char** dest) {
len += taosEncodeFixedI32((void**)&buf, key.len); len += taosEncodeFixedI32((void**)&buf, key.len);
len += taosEncodeFixedI32((void**)&buf, key.rawLen); len += taosEncodeFixedI32((void**)&buf, key.rawLen);
len += taosEncodeFixedI8((void**)&buf, key.compress); len += taosEncodeFixedI8((void**)&buf, key.compress);
if (value != NULL && key.len != 0) {
len += taosEncodeBinary((void**)&buf, (char*)value, key.len); len += taosEncodeBinary((void**)&buf, (char*)value, key.len);
}
*dest = p; *dest = p;
} else { } else {
char* buf = *dest; char* buf = *dest;
@ -2082,8 +2084,10 @@ int32_t valueEncode(void* value, int32_t vlen, int64_t ttl, char** dest) {
len += taosEncodeFixedI32((void**)&buf, key.len); len += taosEncodeFixedI32((void**)&buf, key.len);
len += taosEncodeFixedI32((void**)&buf, key.rawLen); len += taosEncodeFixedI32((void**)&buf, key.rawLen);
len += taosEncodeFixedI8((void**)&buf, key.compress); len += taosEncodeFixedI8((void**)&buf, key.compress);
if (value != NULL && key.len != 0) {
len += taosEncodeBinary((void**)&buf, (char*)value, key.len); len += taosEncodeBinary((void**)&buf, (char*)value, key.len);
} }
}
taosMemoryFree(dst); taosMemoryFree(dst);
return len; return len;