noselasd/libucore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use iomux_add_event/iomux_clear_event in wqueue instead of manually

Browse Source 
doing this
This commit is contained in:
Nils O. Selåsdal
2015-11-10 19:33:30 +01:00
parent 593d29e9fa
commit 42f0493000
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/wqueue.c
+6 -6
View File
@@ -33,9 +33,9 @@ static int uc_wqueue_handle_write(struct UCWQueue *wqueue)
int urc; int urc;
urc = iomux_update_events(mux, urc = iomux_clear_event(mux,
fd, fd,
wqueue->fd.what & ~MUX_EV_WRITE); MUX_EV_WRITE);
assert(urc == 0); assert(urc == 0);
} }
@@ -84,9 +84,9 @@ int uc_wqueue_clear(struct UCWQueue *wqueue)
} }
if ((wqueue->fd.what & MUX_EV_WRITE) != 0) { if ((wqueue->fd.what & MUX_EV_WRITE) != 0) {
rc = iomux_update_events(wqueue->mux, rc = iomux_clear_event(wqueue->mux,
&wqueue->fd, &wqueue->fd,
wqueue->fd.what & ~MUX_EV_WRITE); MUX_EV_WRITE);
} }
assert(rc == 0); assert(rc == 0);
@@ -102,9 +102,9 @@ int uc_wqueue_enqueue(struct UCWQueue *wqueue, struct MBuf *mbuf)
wqueue->queue_len++; wqueue->queue_len++;
if ((wqueue->fd.what & MUX_EV_WRITE) == 0) { if ((wqueue->fd.what & MUX_EV_WRITE) == 0) {
rc = iomux_update_events(wqueue->mux, rc = iomux_add_event(wqueue->mux,
&wqueue->fd, &wqueue->fd,
wqueue->fd.what | MUX_EV_WRITE); MUX_EV_WRITE);
assert(rc == 0); assert(rc == 0);
} }