diff --git a/source/dnode/vnode/src/tsdb/tsdbFS2.c b/source/dnode/vnode/src/tsdb/tsdbFS2.c index 2345cc599b..9b8a979d01 100644 --- a/source/dnode/vnode/src/tsdb/tsdbFS2.c +++ b/source/dnode/vnode/src/tsdb/tsdbFS2.c @@ -731,6 +731,7 @@ _exit: return code; } +// return error code int32_t tsdbOpenFS(STsdb *pTsdb, STFileSystem **fs, int8_t rollback) { int32_t code; int32_t lino; diff --git a/source/dnode/vnode/src/tsdb/tsdbOpen.c b/source/dnode/vnode/src/tsdb/tsdbOpen.c index f9fede1d9b..cf8794770a 100644 --- a/source/dnode/vnode/src/tsdb/tsdbOpen.c +++ b/source/dnode/vnode/src/tsdb/tsdbOpen.c @@ -44,7 +44,7 @@ int64_t tsdbGetEarliestTs(STsdb *pTsdb) { * @param pVnode * @param ppTsdb * @param dir - * @return int + * @return int 0: success, -1: failed */ int tsdbOpen(SVnode *pVnode, STsdb **ppTsdb, const char *dir, STsdbKeepCfg *pKeepCfg, int8_t rollback, bool force) { STsdb *pTsdb = NULL; @@ -79,7 +79,9 @@ int tsdbOpen(SVnode *pVnode, STsdb **ppTsdb, const char *dir, STsdbKeepCfg *pKee } // open tsdb - if (tsdbOpenFS(pTsdb, &pTsdb->pFS, rollback) < 0) { + int32_t code = tsdbOpenFS(pTsdb, &pTsdb->pFS, rollback); + if (code < 0) { + terrno = code; goto _err; }