diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit.c b/source/dnode/vnode/src/tsdb/tsdbCommit.c index 1c634875833bb96bed55c6052b71bead64f894d5..46132012379557b398c1a6bf82feeab54911444d 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCommit.c +++ b/source/dnode/vnode/src/tsdb/tsdbCommit.c @@ -992,16 +992,16 @@ static int32_t tsdbEndCommit(SCommitter *pCommitter, int32_t eno) { ASSERT(eno == 0); - if(inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); + if (inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); code = tsdbFSCommit1(pTsdb, &pCommitter->fs); if (code) { - if(inTrim) taosThreadRwlockUnlock(&pTsdb->rwLock); + if (inTrim) taosThreadRwlockUnlock(&pTsdb->rwLock); goto _err; } // lock - if(!inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); + if (!inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); // commit or rollback code = tsdbFSCommit2(pTsdb, &pCommitter->fs); diff --git a/source/dnode/vnode/src/tsdb/tsdbFS.c b/source/dnode/vnode/src/tsdb/tsdbFS.c index 188810600f10cc938714f0240a9f645ccf7e6f6b..d02cbdc089321f730f6e4c2f9384ba44b9056c2d 100644 --- a/source/dnode/vnode/src/tsdb/tsdbFS.c +++ b/source/dnode/vnode/src/tsdb/tsdbFS.c @@ -717,12 +717,12 @@ _exit: /** * @brief Update or delete DFileSet in pFS according to DFileSet (fid <= maxFid) in pFSNew. - * - * @param pTsdb - * @param pFS - * @param pFSNew + * + * @param pTsdb + * @param pFS + * @param pFSNew * @param maxFid - * @return int32_t + * @return int32_t */ int32_t tsdbFSUpdDel(STsdb *pTsdb, STsdbFS *pFS, STsdbFS *pFSNew, int32_t maxFid) { int32_t code = 0; @@ -817,7 +817,6 @@ _err: return code; } - int32_t tsdbFSCommit1(STsdb *pTsdb, STsdbFS *pFSNew) { int32_t code = 0; char tfname[TSDB_FILENAME_LEN]; @@ -1151,7 +1150,7 @@ _err: return code; } -int32_t tsdbFSRef(STsdb *pTsdb, STsdbFS *pFS) { +int32_t tsdbFSRef(STsdb *pTsdb, STsdbFS *pFS) { int32_t code = 0; int32_t nRef;