From 19db047e3747fa96be14e67e3f87460b65f23521 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sun, 15 Dec 2024 12:25:36 +0800 Subject: [PATCH] telemetry refactor --- include/libs/transport/thttp.h | 4 ---- source/libs/transport/src/thttp.c | 6 +++--- 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/include/libs/transport/thttp.h b/include/libs/transport/thttp.h index ae5e4dfc35..f81895c416 100644 --- a/include/libs/transport/thttp.h +++ b/include/libs/transport/thttp.h @@ -36,10 +36,6 @@ int32_t taosSendHttpReportByChan(const char* server, const char* uri, uint16_t p EHttpCompFlag flag, int64_t chanId, const char* qid); void taosDestroyHttpChan(int64_t chanId); -int32_t taosAllocHttpRecvHandle(int64_t* rid); -void taosFreeHttpRecvHandle(int64_t rid); -int32_t taosGetHttpRecvBufByHandle(int64_t rid, char** pRecv, int32_t* recvLen); - int32_t taosSendRecvHttpReportWithQID(const char* server, const char* uri, uint16_t port, char* pCont, int32_t contLen, EHttpCompFlag flag, const char* qid, int64_t recvBufId); diff --git a/source/libs/transport/src/thttp.c b/source/libs/transport/src/thttp.c index f0a626a222..dc5fb367ea 100644 --- a/source/libs/transport/src/thttp.c +++ b/source/libs/transport/src/thttp.c @@ -964,7 +964,7 @@ void taosDestroyHttpChan(int64_t chanId) { TAOS_UNUSED(taosReleaseRef(httpRefMgt, chanId)); TAOS_UNUSED(taosRemoveRef(httpRefMgt, chanId)); } -int32_t taosAllocHttpRecvHandle(int64_t* rid) { +static int32_t taosAllocHttpRecvHandle(int64_t* rid) { TAOS_UNUSED(taosThreadOnce(&transHttpInit, transHttpEnvInit)); SHttpRecvBuf* p = taosMemoryCalloc(1, sizeof(SHttpRecvBuf)); if (p == NULL) { @@ -980,14 +980,14 @@ int32_t taosAllocHttpRecvHandle(int64_t* rid) { *rid = id; return 0; } -void taosFreeHttpRecvHandle(int64_t rid) { +static void taosFreeHttpRecvHandle(int64_t rid) { if (rid <= 0) { return; } taosReleaseRef(httpRecvRefMgt, rid); taosRemoveRef(httpRecvRefMgt, rid); } -int32_t taosGetHttpRecvById(int64_t rid, char** pRecv, int32_t* len) { +static int32_t taosGetHttpRecvById(int64_t rid, char** pRecv, int32_t* len) { int32_t code = 0; SHttpRecvBuf* p = taosAcquireRef(httpRecvRefMgt, rid); if (p == NULL) {