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

add http test

This commit is contained in:
yihaoDeng 2023-11-23 11:08:23 +08:00
parent 557db1c3cc
commit 321ef1c758
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -196,11 +196,19 @@ static void httpAsyncCb(uv_async_t* handle) {
SHttpMsg *msg = NULL, *quitMsg = NULL; SHttpMsg *msg = NULL, *quitMsg = NULL;
queue wq; queue wq;
QUEUE_INIT(&wq);
static int32_t BACTHSIZE = 20;
int32_t count = 0;
taosThreadMutexLock(&item->mtx); taosThreadMutexLock(&item->mtx);
QUEUE_MOVE(&item->qmsg, &wq); while (!QUEUE_IS_EMPTY(&item->qmsg) && count++ < BACTHSIZE) {
queue* h = QUEUE_HEAD(&item->qmsg);
QUEUE_REMOVE(h);
QUEUE_PUSH(&wq, h);
}
taosThreadMutexUnlock(&item->mtx); taosThreadMutexUnlock(&item->mtx);
int count = 0;
while (!QUEUE_IS_EMPTY(&wq)) { while (!QUEUE_IS_EMPTY(&wq)) {
queue* h = QUEUE_HEAD(&wq); queue* h = QUEUE_HEAD(&wq);
QUEUE_REMOVE(h); QUEUE_REMOVE(h);
@ -370,7 +378,7 @@ static bool httpFailFastShoudIgnoreMsg(SHashObj* pTable, char* server, int16_t p
} }
int64_t now = taosGetTimestampSec(); int64_t now = taosGetTimestampSec();
if (now - *failedTime < 10) { if (now - *failedTime < 60) {
tError("http-report succ to ignore msg,reason:connection timed out, dst:%s", buf); tError("http-report succ to ignore msg,reason:connection timed out, dst:%s", buf);
return true; return true;
} else { } else {