cache/flushState: init flush state when open cache

c56f29c0 · Minglei Jin · 158ae209 · c56f29c0
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

source/dnode/vnode/src/tsdb/tsdbCache.c source/dnode/vnode/src/tsdb/tsdbCache.c +3 -0

未找到文件。
--- a/source/dnode/vnode/src/tsdb/tsdbCache.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCache.c
@@ -1200,6 +1200,9 @@ int32_t tsdbOpenCache(STsdb *pTsdb) {

  taosThreadMutexInit(&pTsdb->lruMutex, NULL);

+  pTsdb->flushState.pTsdb = pTsdb;
+  pTsdb->flushState.flush_count = 0;
+
 _err:
  pTsdb->lruCache = pCache;
  return code;