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

opt transport quit

This commit is contained in:
yihaoDeng 2024-10-30 10:33:50 +08:00
parent a3b797031d
commit 542a6d3672
3 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/transport/inc/transComm.h
View File

@ -353,6 +353,7 @@ typedef struct {
queue node; queue node;
void (*freeFunc)(void* arg); void (*freeFunc)(void* arg);
int32_t size; int32_t size;
int8_t inited;
} STransQueue; } STransQueue;
/* /*

1
source/libs/transport/src/transCli.c
View File

@ -1092,6 +1092,7 @@ _failed:
transQueueDestroy(&conn->reqsToSend); transQueueDestroy(&conn->reqsToSend);
transQueueDestroy(&conn->reqsSentOut); transQueueDestroy(&conn->reqsSentOut);
taosMemoryFree(conn->dstAddr); taosMemoryFree(conn->dstAddr);
taosMemoryFree(conn->ipStr);
} }
tError("failed to create conn, code:%d", code); tError("failed to create conn, code:%d", code);
taosMemoryFree(conn); taosMemoryFree(conn);

2
source/libs/transport/src/transComm.c
View File

@ -423,6 +423,7 @@ int32_t transQueueInit(STransQueue* wq, void (*freeFunc)(void* arg)) {
QUEUE_INIT(&wq->node); QUEUE_INIT(&wq->node);
wq->freeFunc = (void (*)(void*))freeFunc; wq->freeFunc = (void (*)(void*))freeFunc;
wq->size = 0; wq->size = 0;
wq->inited = 1;
return 0; return 0;
} }
void transQueuePush(STransQueue* q, void* arg) { void transQueuePush(STransQueue* q, void* arg) {
@ -497,6 +498,7 @@ void transQueueRemove(STransQueue* q, void* e) {
bool transQueueEmpty(STransQueue* q) { return q->size == 0 ? true : false; } bool transQueueEmpty(STransQueue* q) { return q->size == 0 ? true : false; }
void transQueueClear(STransQueue* q) { void transQueueClear(STransQueue* q) {
if (q->inited == 0) return;
while (!QUEUE_IS_EMPTY(&q->node)) { while (!QUEUE_IS_EMPTY(&q->node)) {
queue* h = QUEUE_HEAD(&q->node); queue* h = QUEUE_HEAD(&q->node);
QUEUE_REMOVE(h); QUEUE_REMOVE(h);