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

extern function: sf_task_detach_thread

connection_manager
YuQing 2020-09-12 21:32:50 +08:00
parent cabb6a897c
commit a57d52be92
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/sf_nio.c
View File

@ -38,7 +38,7 @@ void sf_set_parameters_ex(SFContext *sf_context, const int header_size,
sf_context->timeout_callback = timeout_callback; sf_context->timeout_callback = timeout_callback;
} }
static void sf_task_detach_thread(struct fast_task_info *task) void sf_task_detach_thread(struct fast_task_info *task)
{ {
ioevent_detach(&task->thread_data->ev_puller, task->event.fd); ioevent_detach(&task->thread_data->ev_puller, task->event.fd);
@ -213,6 +213,8 @@ static int sf_connect_server(struct fast_task_info *task)
return sf_ioevent_add(task, (IOEventCallback) return sf_ioevent_add(task, (IOEventCallback)
sf_client_sock_connect, task->connect_timeout); sf_client_sock_connect, task->connect_timeout);
} else { } else {
close(task->event.fd);
task->event.fd = -1;
logError("file: "__FILE__", line: %d, " logError("file: "__FILE__", line: %d, "
"connect to server %s:%d fail, errno: %d, " "connect to server %s:%d fail, errno: %d, "
"error info: %s", __LINE__, task->server_ip, "error info: %s", __LINE__, task->server_ip,

2
src/sf_nio.h
View File

@ -61,6 +61,8 @@ int sf_set_read_event(struct fast_task_info *task);
void sf_task_switch_thread(struct fast_task_info *task, void sf_task_switch_thread(struct fast_task_info *task,
const int new_thread_index); const int new_thread_index);
void sf_task_detach_thread(struct fast_task_info *task);
static inline int sf_nio_forward_request(struct fast_task_info *task, static inline int sf_nio_forward_request(struct fast_task_info *task,
const int new_thread_index) const int new_thread_index)
{ {