commit
ad4e7e9fbb
|
@ -126,6 +126,8 @@ int tsdbCloseRepo(STsdbRepo *repo, int toCommit) {
|
||||||
tsdbSyncCommit(repo);
|
tsdbSyncCommit(repo);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
tsem_wait(&(pRepo->readyToCommit));
|
||||||
|
|
||||||
tsdbUnRefMemTable(pRepo, pRepo->mem);
|
tsdbUnRefMemTable(pRepo, pRepo->mem);
|
||||||
tsdbUnRefMemTable(pRepo, pRepo->imem);
|
tsdbUnRefMemTable(pRepo, pRepo->imem);
|
||||||
pRepo->mem = NULL;
|
pRepo->mem = NULL;
|
||||||
|
|
Loading…
Reference in New Issue