server_common/f8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2019-07-31 18:46:05 +08:00
parent c71e7fb8b5
commit b58ab4434b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cpp/httpclientpool.cc
View File

@ -177,7 +177,7 @@ namespace f8
long long begin_tick = a8::XGetTickCount(); long long begin_tick = a8::XGetTickCount();
ret = a8::http::Get(finally_url, response, &node->headers, 10); ret = a8::http::Get(finally_url, response, &node->headers, 10);
long long end_tick = a8::XGetTickCount(); long long end_tick = a8::XGetTickCount();
if (thread_id <= f8::HttpClientPool::Instance()->sys_num) { if (thread_id < f8::HttpClientPool::Instance()->sys_num) {
if (end_tick - begin_tick > f8::HttpClientPool::Instance()->max_sys_request_delay) { if (end_tick - begin_tick > f8::HttpClientPool::Instance()->max_sys_request_delay) {
f8::HttpClientPool::Instance()->max_sys_request_delay = end_tick - begin_tick; f8::HttpClientPool::Instance()->max_sys_request_delay = end_tick - begin_tick;
} }
@ -193,7 +193,7 @@ namespace f8
long long begin_tick = a8::XGetTickCount(); long long begin_tick = a8::XGetTickCount();
ret = a8::http::Post(finally_url.c_str(), node->content, response, &node->headers, 10); ret = a8::http::Post(finally_url.c_str(), node->content, response, &node->headers, 10);
long long end_tick = a8::XGetTickCount(); long long end_tick = a8::XGetTickCount();
if (thread_id <= f8::HttpClientPool::Instance()->sys_num) { if (thread_id < f8::HttpClientPool::Instance()->sys_num) {
if (end_tick - begin_tick > f8::HttpClientPool::Instance()->max_sys_request_delay) { if (end_tick - begin_tick > f8::HttpClientPool::Instance()->max_sys_request_delay) {
f8::HttpClientPool::Instance()->max_sys_request_delay = end_tick - begin_tick; f8::HttpClientPool::Instance()->max_sys_request_delay = end_tick - begin_tick;
} }