This commit is contained in:
Shengliang Guan 2020-08-08 21:34:56 +08:00
parent 95f764060c
commit b1473342e4
3 changed files with 3 additions and 3 deletions

View File

@ -360,7 +360,7 @@ find_shared_library_fullname ()
ungetc (c, fp); ungetc (c, fp);
shared_library_fullname = NULL; size = 0; shared_library_fullname = NULL; size = 0;
len = taosGetline(&shared_library_fullname, &size, fp); len = getline(&shared_library_fullname, &size, fp);
if (len >= 0) if (len >= 0)
{ {
/* Success: filled shared_library_fullname. */ /* Success: filled shared_library_fullname. */

View File

@ -912,7 +912,7 @@ int tscBuildQueryMsg(SSqlObj *pSql, SSqlInfo *pInfo) {
pSql->cmd.msgType = TSDB_MSG_TYPE_QUERY; pSql->cmd.msgType = TSDB_MSG_TYPE_QUERY;
pQueryMsg->head.contLen = htonl(msgLen); pQueryMsg->head.contLen = htonl(msgLen);
assert(msgLen + minMsgSize() <= pCmd->allocSize); assert(msgLen + minMsgSize() <= (int32_t)pCmd->allocSize);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }

View File

@ -426,7 +426,7 @@ TAOS_RES *taos_consume(TAOS_SUB *tsub) {
size_t size = taosArrayGetSize(pSub->progress) * sizeof(STableIdInfo); size_t size = taosArrayGetSize(pSub->progress) * sizeof(STableIdInfo);
size += sizeof(SQueryTableMsg) + 4096; size += sizeof(SQueryTableMsg) + 4096;
tscAllocPayload(&pSql->cmd, size); tscAllocPayload(&pSql->cmd, (int)size);
for (int retry = 0; retry < 3; retry++) { for (int retry = 0; retry < 3; retry++) {
tscRemoveFromSqlList(pSql); tscRemoveFromSqlList(pSql);