xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix crash while quit

This commit is contained in:
yihaoDeng 2023-11-28 20:29:42 +08:00
parent 08eeee0794
commit cc1eb2769f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -1844,6 +1844,9 @@ void taskDbDestroy(void* pDb, bool flush) {
rocksdb_column_family_handle_destroy(wrapper->pCf[i]); rocksdb_column_family_handle_destroy(wrapper->pCf[i]);
} }
} }
if (wrapper->db) rocksdb_close(wrapper->db);
rocksdb_options_destroy(wrapper->dbOpt); rocksdb_options_destroy(wrapper->dbOpt);
rocksdb_readoptions_destroy(wrapper->readOpt); rocksdb_readoptions_destroy(wrapper->readOpt);
rocksdb_writeoptions_destroy(wrapper->writeOpt); rocksdb_writeoptions_destroy(wrapper->writeOpt);
@ -1851,7 +1854,6 @@ void taskDbDestroy(void* pDb, bool flush) {
rocksdb_cache_destroy(wrapper->cache); rocksdb_cache_destroy(wrapper->cache);
taosMemoryFree(wrapper->pCf); taosMemoryFree(wrapper->pCf);
for (int i = 0; i < nCf; i++) { for (int i = 0; i < nCf; i++) {
rocksdb_options_t* opt = wrapper->pCfOpts[i]; rocksdb_options_t* opt = wrapper->pCfOpts[i];
rocksdb_comparator_t* compare = wrapper->pCompares[i]; rocksdb_comparator_t* compare = wrapper->pCompares[i];
@ -1867,8 +1869,6 @@ void taskDbDestroy(void* pDb, bool flush) {
taosThreadMutexDestroy(&wrapper->mutex); taosThreadMutexDestroy(&wrapper->mutex);
if (wrapper->db) rocksdb_close(wrapper->db);
taskDbDestroyChkpOpt(wrapper); taskDbDestroyChkpOpt(wrapper);
taosMemoryFree(wrapper->idstr); taosMemoryFree(wrapper->idstr);