提交 2cb6c7af 编写于 作者: M Minglei Jin

cache/commit: use outter lock

上级 9d6a22e3
...@@ -333,8 +333,8 @@ int32_t tsdbCacheCommit(STsdb *pTsdb) { ...@@ -333,8 +333,8 @@ int32_t tsdbCacheCommit(STsdb *pTsdb) {
taosLRUCacheApply(pCache, tsdbCacheFlushDirty, &pTsdb->flushState); taosLRUCacheApply(pCache, tsdbCacheFlushDirty, &pTsdb->flushState);
rocksMayWrite(pTsdb, true, false, true); rocksMayWrite(pTsdb, true, false, false);
rocksMayWrite(pTsdb, true, true, true); rocksMayWrite(pTsdb, true, true, false);
rocksdb_flush(pTsdb->rCache.db, pTsdb->rCache.flushoptions, &err); rocksdb_flush(pTsdb->rCache.db, pTsdb->rCache.flushoptions, &err);
taosThreadMutexUnlock(&pTsdb->lruMutex); taosThreadMutexUnlock(&pTsdb->lruMutex);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册