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

add compress

This commit is contained in:
Yihao Deng 2024-04-17 08:38:46 +00:00
parent 1363cd0a71
commit 15f9e1e29e
1 changed files with 2 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

@ -1615,9 +1615,9 @@ int32_t valueDecode(void* value, int32_t vlen, int64_t* ttl, char** dest) {
} }
if (key.compress == 1) { if (key.compress == 1) {
char* pCompressData = NULL; char* pCompressData = NULL;
if (key.len != 0 && *dest != NULL) { if (key.len != 0) {
p = taosDecodeBinary(p, (void**)&pCompressData, key.len); p = taosDecodeBinary(p, (void**)&pCompressData, key.len);
*dest = taosMemoryCalloc(1, key.rawLen); if (*dest) *dest = taosMemoryCalloc(1, key.rawLen);
int32_t decompressSize = LZ4_decompress_safe(pCompressData, *dest, key.len, key.rawLen); int32_t decompressSize = LZ4_decompress_safe(pCompressData, *dest, key.len, key.rawLen);
ASSERT(decompressSize == key.rawLen); ASSERT(decompressSize == key.rawLen);
key.len = decompressSize; key.len = decompressSize;