[TBASE-1213]
This commit is contained in:
parent
2ae838b690
commit
d8292d6630
|
@ -63,7 +63,7 @@
|
||||||
#define HTTP_WRITE_RETRY_TIMES 500
|
#define HTTP_WRITE_RETRY_TIMES 500
|
||||||
#define HTTP_WRITE_WAIT_TIME_MS 5
|
#define HTTP_WRITE_WAIT_TIME_MS 5
|
||||||
#define HTTP_EXPIRED_TIME 60000
|
#define HTTP_EXPIRED_TIME 60000
|
||||||
#define HTTP_DELAY_CLOSE_TIME_MS 1000
|
#define HTTP_DELAY_CLOSE_TIME_MS 500
|
||||||
|
|
||||||
#define HTTP_COMPRESS_IDENTITY 0
|
#define HTTP_COMPRESS_IDENTITY 0
|
||||||
#define HTTP_COMPRESS_GZIP 2
|
#define HTTP_COMPRESS_GZIP 2
|
||||||
|
|
|
@ -107,9 +107,9 @@ void httpCleanUpContextTimer(HttpContext *pContext) {
|
||||||
}
|
}
|
||||||
|
|
||||||
void httpCleanUpContext(HttpContext *pContext) {
|
void httpCleanUpContext(HttpContext *pContext) {
|
||||||
httpTrace("context:%p, start the clean up operation", pContext);
|
httpTrace("context:%p, start the clean up operation, sig:%p", pContext, pContext->signature);
|
||||||
atomic_val_compare_exchange_ptr(&pContext->signature, pContext, 0);
|
void *sig = atomic_val_compare_exchange_ptr(&pContext->signature, pContext, 0);
|
||||||
if (pContext->signature != NULL) {
|
if (sig == NULL) {
|
||||||
httpTrace("context:%p is freed by another thread.", pContext);
|
httpTrace("context:%p is freed by another thread.", pContext);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
@ -89,7 +89,7 @@ int httpStartSystem() {
|
||||||
}
|
}
|
||||||
|
|
||||||
if (httpServer->timerHandle == NULL) {
|
if (httpServer->timerHandle == NULL) {
|
||||||
httpServer->timerHandle = taosTmrInit(tsHttpCacheSessions * 20 + 100, 1000, 60000, "http");
|
httpServer->timerHandle = taosTmrInit(tsHttpCacheSessions * 20 + 100, 200, 60000, "http");
|
||||||
}
|
}
|
||||||
if (httpServer->timerHandle == NULL) {
|
if (httpServer->timerHandle == NULL) {
|
||||||
httpError("http init timer failed");
|
httpError("http init timer failed");
|
||||||
|
|
Loading…
Reference in New Issue