From 42f049300084e688ced1a104bd01bbd5859ee3a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nils=20O=2E=20Sel=C3=A5sdal?= Date: Tue, 10 Nov 2015 19:33:30 +0100 Subject: [PATCH] Use iomux_add_event/iomux_clear_event in wqueue instead of manually doing this --- src/wqueue.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/wqueue.c b/src/wqueue.c index 8e7505f..4401440 100644 --- a/src/wqueue.c +++ b/src/wqueue.c @@ -33,9 +33,9 @@ static int uc_wqueue_handle_write(struct UCWQueue *wqueue) int urc; - urc = iomux_update_events(mux, + urc = iomux_clear_event(mux, fd, - wqueue->fd.what & ~MUX_EV_WRITE); + MUX_EV_WRITE); assert(urc == 0); } @@ -84,9 +84,9 @@ int uc_wqueue_clear(struct UCWQueue *wqueue) } if ((wqueue->fd.what & MUX_EV_WRITE) != 0) { - rc = iomux_update_events(wqueue->mux, + rc = iomux_clear_event(wqueue->mux, &wqueue->fd, - wqueue->fd.what & ~MUX_EV_WRITE); + MUX_EV_WRITE); } assert(rc == 0); @@ -102,9 +102,9 @@ int uc_wqueue_enqueue(struct UCWQueue *wqueue, struct MBuf *mbuf) wqueue->queue_len++; if ((wqueue->fd.what & MUX_EV_WRITE) == 0) { - rc = iomux_update_events(wqueue->mux, + rc = iomux_add_event(wqueue->mux, &wqueue->fd, - wqueue->fd.what | MUX_EV_WRITE); + MUX_EV_WRITE); assert(rc == 0); }