test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-02 03:47:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fiber: adding iocp event

Browse Source
This commit is contained in:
郑树新 2018-01-31 19:16:23 +08:00
parent 2af5a9307f
commit a16c4122d0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib_fiber/c/src/event/event_iocp.c
View File

@ -305,11 +305,11 @@ static void iocp_set_all(EVENT_IOCP *ev)
for (i = 0; i < ev->count; i++) {
FILE_EVENT *fe = ev->files[i];
if (fe->reader && !(fe->reader->type & IOCP_EVENT_READ)) {
if (!fe->reader || !(fe->reader->type & IOCP_EVENT_READ)) {
iocp_add_read(ev, fe);
n++;
}
if (fe->writer && !(fe->writer->type & IOCP_EVENT_WRITE)) {
if (!fe->writer || !(fe->writer->type & IOCP_EVENT_WRITE)) {
iocp_add_write(ev, fe);
n++;
}
@ -356,13 +356,13 @@ static int iocp_wait(EVENT *ev, int timeout)
if ((event->type & IOCP_EVENT_READ) && fe->r_proc) {
assert(fe->reader == event);
iocp_del_read(ei, fe);
//iocp_del_read(ei, fe);
array_append(readers, fe);
}
if ((event->type & IOCP_EVENT_WRITE) && fe->w_proc) {
assert(fe->writer == event);
iocp_del_write(ei, fe);
//iocp_del_write(ei, fe);
array_append(writers, fe);
}