fix: check error code

This commit is contained in:
Liu Jicong 2022-06-14 15:22:39 +08:00
parent acda336f4e
commit 79d9c04a4c
1 changed files with 1 additions and 1 deletions

View File

@ -50,7 +50,7 @@ STqOffsetStore* tqOffsetOpen(STQ* pTq) {
while (1) { while (1) {
if ((code = taosReadFile(pFile, &head, sizeof(STqOffsetHead))) != sizeof(STqOffsetHead)) { if ((code = taosReadFile(pFile, &head, sizeof(STqOffsetHead))) != sizeof(STqOffsetHead)) {
if (code < 0) { if (code == 0) {
break; break;
} else { } else {
ASSERT(0); ASSERT(0);