change transport param
This commit is contained in:
parent
8dcd73abf0
commit
b36b34c1bb
|
@ -778,7 +778,7 @@ static void cliSendCb(uv_write_t* req, int status) {
|
||||||
SCliMsg* pMsg = !transQueueEmpty(&pConn->cliMsgs) ? transQueueGet(&pConn->cliMsgs, 0) : NULL;
|
SCliMsg* pMsg = !transQueueEmpty(&pConn->cliMsgs) ? transQueueGet(&pConn->cliMsgs, 0) : NULL;
|
||||||
if (pMsg != NULL) {
|
if (pMsg != NULL) {
|
||||||
int64_t cost = taosGetTimestampUs() - pMsg->st;
|
int64_t cost = taosGetTimestampUs() - pMsg->st;
|
||||||
if (cost > 1000) {
|
if (cost > 1000 * 20) {
|
||||||
tWarn("%s conn %p send cost:%dus, send exception", CONN_GET_INST_LABEL(pConn), pConn, (int)cost);
|
tWarn("%s conn %p send cost:%dus, send exception", CONN_GET_INST_LABEL(pConn), pConn, (int)cost);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue