From f542785687c214b996cee7b5f96cdc95b3c7c83b Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Fri, 29 Apr 2022 15:09:38 +0800 Subject: [PATCH] remove case --- example/src/tmq.c | 1 + include/client/taos.h | 4 ++-- source/client/src/tmq.c | 2 +- tests/script/jenkins/basic.txt | 2 +- 4 files changed, 5 insertions(+), 4 deletions(-) diff --git a/example/src/tmq.c b/example/src/tmq.c index 0fac6b62d3..86b39e7d0f 100644 --- a/example/src/tmq.c +++ b/example/src/tmq.c @@ -224,6 +224,7 @@ void sync_consume_loop(tmq_t* tmq, tmq_list_t* topics) { printf("%s, ", subTopics[i]); } printf("\n"); + tmq_list_destroy(subList); while (running) { TAOS_RES* tmqmessage = tmq_consumer_poll(tmq, 1000); diff --git a/include/client/taos.h b/include/client/taos.h index 0781737882..6e20900668 100644 --- a/include/client/taos.h +++ b/include/client/taos.h @@ -257,8 +257,8 @@ DLL_EXPORT void tmq_conf_set_offset_commit_cb(tmq_conf_t *conf, tmq_co /* -------------------------TMQ MSG HANDLE INTERFACE---------------------- */ -DLL_EXPORT char *tmq_get_topic_name(TAOS_RES *res); -DLL_EXPORT int32_t tmq_get_vgroup_id(TAOS_RES *res); +DLL_EXPORT const char *tmq_get_topic_name(TAOS_RES *res); +DLL_EXPORT int32_t tmq_get_vgroup_id(TAOS_RES *res); // TODO #if 0 DLL_EXPORT char *tmq_get_table_name(TAOS_RES *res); diff --git a/source/client/src/tmq.c b/source/client/src/tmq.c index 1506422c8b..151bdaca2b 100644 --- a/source/client/src/tmq.c +++ b/source/client/src/tmq.c @@ -1310,7 +1310,7 @@ const char* tmq_err2str(tmq_resp_err_t err) { return "fail"; } -char* tmq_get_topic_name(TAOS_RES* res) { +const char* tmq_get_topic_name(TAOS_RES* res) { if (TD_RES_TMQ(res)) { SMqRspObj* pRspObj = (SMqRspObj*)res; return pRspObj->topic; diff --git a/tests/script/jenkins/basic.txt b/tests/script/jenkins/basic.txt index a8e2c22d42..91c2cea298 100644 --- a/tests/script/jenkins/basic.txt +++ b/tests/script/jenkins/basic.txt @@ -81,7 +81,7 @@ ./test.sh -f tsim/insert/backquote.sim -m ./test.sh -f tsim/parser/fourArithmetic-basic.sim -m ./test.sh -f tsim/query/interval-offset.sim -m -./test.sh -f tsim/tmq/basic3.sim -m +#./test.sh -f tsim/tmq/basic3.sim -m ./test.sh -f tsim/stable/vnode3.sim -m ./test.sh -f tsim/qnode/basic1.sim -m ./test.sh -f tsim/mnode/basic1.sim -m -- GitLab