xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

telemetry refactor

This commit is contained in:
yihaoDeng 2024-12-15 12:25:36 +08:00
parent d4b4c35159
commit 19db047e37
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/libs/transport/thttp.h
View File

@ -36,10 +36,6 @@ int32_t taosSendHttpReportByChan(const char* server, const char* uri, uint16_t p
EHttpCompFlag flag, int64_t chanId, const char* qid); EHttpCompFlag flag, int64_t chanId, const char* qid);
void taosDestroyHttpChan(int64_t chanId); 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, 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); EHttpCompFlag flag, const char* qid, int64_t recvBufId);

6
source/libs/transport/src/thttp.c
View File

@ -964,7 +964,7 @@ void taosDestroyHttpChan(int64_t chanId) {
TAOS_UNUSED(taosReleaseRef(httpRefMgt, chanId)); TAOS_UNUSED(taosReleaseRef(httpRefMgt, chanId));
TAOS_UNUSED(taosRemoveRef(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)); TAOS_UNUSED(taosThreadOnce(&transHttpInit, transHttpEnvInit));
SHttpRecvBuf* p = taosMemoryCalloc(1, sizeof(SHttpRecvBuf)); SHttpRecvBuf* p = taosMemoryCalloc(1, sizeof(SHttpRecvBuf));
if (p == NULL) { if (p == NULL) {
@ -980,14 +980,14 @@ int32_t taosAllocHttpRecvHandle(int64_t* rid) {
*rid = id; *rid = id;
return 0; return 0;
} }
void taosFreeHttpRecvHandle(int64_t rid) { static void taosFreeHttpRecvHandle(int64_t rid) {
if (rid <= 0) { if (rid <= 0) {
return; return;
} }
taosReleaseRef(httpRecvRefMgt, rid); taosReleaseRef(httpRecvRefMgt, rid);
taosRemoveRef(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; int32_t code = 0;
SHttpRecvBuf* p = taosAcquireRef(httpRecvRefMgt, rid); SHttpRecvBuf* p = taosAcquireRef(httpRecvRefMgt, rid);
if (p == NULL) { if (p == NULL) {