From 59ff6bd3015584bef1b61426d2f7707b39ae2206 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 11 May 2023 09:32:44 +0000 Subject: [PATCH] factor code --- source/libs/stream/src/streamBackendRocksdb.c | 1 + source/libs/stream/src/tstreamFileState.c | 5 ++--- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 93870006b3..d8524dc5d9 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -15,6 +15,7 @@ #include "streamBackendRocksdb.h" #include "executor.h" +#include "query.h" #include "tcommon.h" typedef struct SCompactFilteFactory { diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c index b7401ec5d9..ac2b869af3 100644 --- a/source/libs/stream/src/tstreamFileState.c +++ b/source/libs/stream/src/tstreamFileState.c @@ -15,6 +15,7 @@ #include "tstreamFileState.h" +#include "query.h" #include "streamBackendRocksdb.h" #include "taos.h" #include "tcommon.h" @@ -154,9 +155,7 @@ void streamFileStateClear(SStreamFileState* pFileState) { clearExpiredRowBuff(pFileState, 0, true); } -bool needClearDiskBuff(SStreamFileState* pFileState) { - return pFileState->flushMark > 0; -} +bool needClearDiskBuff(SStreamFileState* pFileState) { return pFileState->flushMark > 0; } void popUsedBuffs(SStreamFileState* pFileState, SStreamSnapshot* pFlushList, uint64_t max, bool used) { uint64_t i = 0; -- GitLab