diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 8d86f046ef5dcb0ae55f75683430a93b2814c683..0613f3524271ed0474f16ff1437ea61aea35cab7 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -199,17 +199,20 @@ void tscProcessActivityTimer(void *handle, void *tmrId) { pObj->pHb = pSql; tscAddSubqueryInfo(&pObj->pHb->cmd); - tscDebug("%p pHb is allocated, pObj:%p", pObj->pHb, pObj); + tscDebug("%p HB is allocated, pObj:%p", pObj->pHb, pObj); } if (tscShouldFreeHeatBeat(pObj->pHb)) { - tscDebug("%p free HB object and release connection", pObj); + tscDebug("%p free HB object and release connection", pObj->pHb); tscFreeSqlObj(pObj->pHb); tscCloseTscObj(pObj); - return; + } else { +// taosMsleep(500); + int32_t code = tscProcessSql(pObj->pHb); + if (code != TSDB_CODE_SUCCESS) { + tscError("%p failed to sent HB to server, reason:%s", pObj->pHb, tstrerror(code)); + } } - - tscProcessSql(pObj->pHb); } int tscSendMsgToServer(SSqlObj *pSql) { diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c index 2c48c76b1ccdca0f78fa0ba627773eff9423d353..94ab3a0c75acba62d9070c8549e17349fa3f0ac2 100644 --- a/src/client/src/tscSql.c +++ b/src/client/src/tscSql.c @@ -181,6 +181,7 @@ TAOS *taos_connect(const char *ip, const char *user, const char *pass, const cha return NULL; } + TAOS *taos_connect_c(const char *ip, uint8_t ipLen, const char *user, uint8_t userLen, const char *pass, uint8_t passLen, const char *db, uint8_t dbLen, uint16_t port) { char ipBuf[TSDB_EP_LEN] = {0};