diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h index 75ca4b62408fad1c8eada83ba2c7c0c9b1d71d72..c8754e5bebd7a460ed3e33a5e56a1e535dbf7035 100644 --- a/src/client/inc/tsclient.h +++ b/src/client/inc/tsclient.h @@ -395,7 +395,6 @@ TAOS *taos_connect_a(char *ip, char *user, char *pass, char *db, uint16_t port, void *param, void **taos); void waitForQueryRsp(void *param, TAOS_RES *tres, int code) ; -int doAsyncParseSql(SSqlObj* pSql); void doAsyncQuery(STscObj *pObj, SSqlObj *pSql, void (*fp)(), void *param, const char *sqlstr, size_t sqlLen); void tscProcessMultiVnodesImportFromFile(SSqlObj *pSql); @@ -403,13 +402,14 @@ void tscKillSTableQuery(SSqlObj *pSql); void tscInitResObjForLocalQuery(SSqlObj *pObj, int32_t numOfRes, int32_t rowLen); bool tscIsUpdateQuery(SSqlObj* pSql); bool tscHasReachLimitation(SQueryInfo *pQueryInfo, SSqlRes *pRes); + +// todo remove this function. bool tscResultsetFetchCompleted(TAOS_RES *result); char *tscGetErrorMsgPayload(SSqlCmd *pCmd); int32_t tscInvalidSQLErrMsg(char *msg, const char *additionalInfo, const char *sql); -void tscQueueAsyncFreeResult(SSqlObj *pSql); int32_t tscToSQLCmd(SSqlObj *pSql, struct SSqlInfo *pInfo); void tscGetResultColumnChr(SSqlRes *pRes, SFieldInfo* pFieldInfo, int32_t column); diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c index 5c57594a68542f21c74e71f7de6742920aeb3a3e..100c9029a78cb2d74a13c6d84c7c85f34197b0e0 100644 --- a/src/client/src/tscAsync.c +++ b/src/client/src/tscAsync.c @@ -412,17 +412,6 @@ void tscProcessAsyncFree(SSchedMsg *pMsg) { taos_free_result(pSql); } -void tscQueueAsyncFreeResult(SSqlObj *pSql) { - tscDebug("%p sqlObj put in queue to async free", pSql); - - SSchedMsg schedMsg = { 0 }; - schedMsg.fp = tscProcessAsyncFree; - schedMsg.ahandle = pSql; - schedMsg.thandle = (void *)1; - schedMsg.msg = NULL; - taosScheduleTask(tscQhandle, &schedMsg); -} - int tscSendMsgToServer(SSqlObj *pSql); void tscTableMetaCallBack(void *param, TAOS_RES *res, int code) {