提交 dc1a04e6 编写于 作者: H Hongze Cheng

TD-353

上级 f1ce0225
...@@ -147,9 +147,11 @@ void tsdbCloseRepo(TSDB_REPO_T *repo, int toCommit) { ...@@ -147,9 +147,11 @@ void tsdbCloseRepo(TSDB_REPO_T *repo, int toCommit) {
if (toCommit) { if (toCommit) {
tsdbAsyncCommit(pRepo); tsdbAsyncCommit(pRepo);
if (pRepo->commit) pthread_join(pRepo->commitThread, NULL); if (pRepo->commit) pthread_join(pRepo->commitThread, NULL);
} else {
// TODO
} }
tsdbUnRefMemTable(pRepo, pRepo->mem);
tsdbUnRefMemTable(pRepo, pRepo->imem);
pRepo->mem = NULL;
pRepo->imem = NULL;
tsdbCloseFileH(pRepo); tsdbCloseFileH(pRepo);
tsdbCloseBufPool(pRepo); tsdbCloseBufPool(pRepo);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册