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

clear nio_stages.notify when task canceled

connection_manager
YuQing 2020-10-27 08:56:31 +08:00
parent b9e22e61fc
commit 946bd8fe46
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/sf_nio.c
View File

@ -348,6 +348,7 @@ int sf_nio_notify(struct fast_task_info *task, const int stage)
void sf_recv_notify_read(int sock, short event, void *arg) void sf_recv_notify_read(int sock, short event, void *arg)
{ {
int64_t n; int64_t n;
int stage;
struct nio_thread_data *thread_data; struct nio_thread_data *thread_data;
struct fast_task_info *task; struct fast_task_info *task;
struct fast_task_info *current; struct fast_task_info *current;
@ -370,6 +371,12 @@ void sf_recv_notify_read(int sock, short event, void *arg)
if (!task->canceled) { if (!task->canceled) {
sf_nio_deal_task(task); sf_nio_deal_task(task);
} else {
stage = __sync_add_and_fetch(&task->nio_stages.notify, 0);
if (stage != SF_NIO_STAGE_NONE) {
__sync_bool_compare_and_swap(&task->nio_stages.notify,
stage, SF_NIO_STAGE_NONE);
}
} }
} }
} }