提交 70f2c685 编写于 作者: C Cary Xu

chore: code format

上级 b7253d88
...@@ -992,16 +992,16 @@ static int32_t tsdbEndCommit(SCommitter *pCommitter, int32_t eno) { ...@@ -992,16 +992,16 @@ static int32_t tsdbEndCommit(SCommitter *pCommitter, int32_t eno) {
ASSERT(eno == 0); ASSERT(eno == 0);
if(inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); if (inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock);
code = tsdbFSCommit1(pTsdb, &pCommitter->fs); code = tsdbFSCommit1(pTsdb, &pCommitter->fs);
if (code) { if (code) {
if(inTrim) taosThreadRwlockUnlock(&pTsdb->rwLock); if (inTrim) taosThreadRwlockUnlock(&pTsdb->rwLock);
goto _err; goto _err;
} }
// lock // lock
if(!inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock); if (!inTrim) taosThreadRwlockWrlock(&pTsdb->rwLock);
// commit or rollback // commit or rollback
code = tsdbFSCommit2(pTsdb, &pCommitter->fs); code = tsdbFSCommit2(pTsdb, &pCommitter->fs);
......
...@@ -817,7 +817,6 @@ _err: ...@@ -817,7 +817,6 @@ _err:
return code; return code;
} }
int32_t tsdbFSCommit1(STsdb *pTsdb, STsdbFS *pFSNew) { int32_t tsdbFSCommit1(STsdb *pTsdb, STsdbFS *pFSNew) {
int32_t code = 0; int32_t code = 0;
char tfname[TSDB_FILENAME_LEN]; char tfname[TSDB_FILENAME_LEN];
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册