pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

set last_report_time correctly

connection_manager
YuQing 2020-09-16 14:38:58 +08:00
parent 4d1dfb9cab
commit 4db063335f
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/idempotency/client/client_channel.c
View File

@ -65,7 +65,7 @@ static int load_client_channel_config(IniFullContext *ini_ctx)
g_idempotency_client_cfg.channel_max_idle_time = iniGetIntValue( g_idempotency_client_cfg.channel_max_idle_time = iniGetIntValue(
ini_ctx->section_name, "channel_max_idle_time", ini_ctx->section_name, "channel_max_idle_time",
ini_ctx->context, 3); ini_ctx->context, 300);
return 0; return 0;
} }

11
src/idempotency/client/receipt_handler.c
View File

@ -51,10 +51,13 @@ static int receipt_recv_timeout_callback(struct fast_task_info *task)
logError("file: "__FILE__", line: %d, " logError("file: "__FILE__", line: %d, "
"waiting receipt response from server %s:%d timeout", "waiting receipt response from server %s:%d timeout",
__LINE__, task->server_ip, task->port); __LINE__, task->server_ip, task->port);
return ETIMEDOUT; } else {
logError("file: "__FILE__", line: %d, "
"communication with server %s:%d timeout",
__LINE__, task->server_ip, task->port);
} }
return 0; return ETIMEDOUT;
} }
static void receipt_task_finish_cleanup(struct fast_task_info *task) static void receipt_task_finish_cleanup(struct fast_task_info *task)
@ -214,11 +217,13 @@ static int report_req_receipt_request(struct fast_task_info *task,
if (count == 0) { if (count == 0) {
result = sf_set_read_event(task); result = sf_set_read_event(task);
} else if (update_lru) { } else {
((IdempotencyClientChannel *)task->arg)-> ((IdempotencyClientChannel *)task->arg)->
last_report_time = g_current_time; last_report_time = g_current_time;
if (update_lru) {
update_lru_chain(task); update_lru_chain(task);
} }
}
return 0; return 0;
} }