From cfc6bd9f9ff7f1f8f5faa342fa2b4d0e22bfeaf5 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 12 May 2023 02:10:40 +0000 Subject: [PATCH] factor code --- source/libs/stream/src/streamBackendRocksdb.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index e34fc69de0..1cb2311944 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -111,6 +111,9 @@ void* streamBackendInit(const char* path) { taosMemoryFreeClear(err); } } else { + /* + list all cf and get prefix + */ int64_t streamId; int32_t taskId, dummpy = 0; SHashObj* tbl = taosHashInit(32, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_NO_LOCK); @@ -650,10 +653,7 @@ const char* compactFilteFactoryName(void* arg) { void destroyCompactFilte(void* arg) { (void)arg; } unsigned char compactFilte(void* arg, int level, const char* key, size_t klen, const char* val, size_t vlen, char** newval, size_t* newvlen, unsigned char* value_changed) { - if (streamStateValueIsStale((char*)val)) { - return 1; - } - return 0; + return streamStateValueIsStale((char*)val) ? 1 : 0 } const char* compactFilteName(void* arg) { return "stream_filte"; }