fix(analytics): fix check return value error.
This commit is contained in:
parent
c8b44b82c4
commit
9198164ac6
|
@ -478,11 +478,13 @@ static int32_t taosAnalJsonBufWriteStrUseCol(SAnalyticBuf *pBuf, const char *buf
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pBuf->bufType == ANALYTICS_BUF_TYPE_JSON) {
|
if (pBuf->bufType == ANALYTICS_BUF_TYPE_JSON) {
|
||||||
if (taosWriteFile(pBuf->filePtr, buf, bufLen) != bufLen) {
|
int32_t ret = taosWriteFile(pBuf->filePtr, buf, bufLen);
|
||||||
|
if (ret < 0) {
|
||||||
return terrno;
|
return terrno;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
if (taosWriteFile(pBuf->pCols[colIndex].filePtr, buf, bufLen) != bufLen) {
|
int32_t ret = taosWriteFile(pBuf->pCols[colIndex].filePtr, buf, bufLen);
|
||||||
|
if (ret < 0) {
|
||||||
return terrno;
|
return terrno;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue