From 8e8cf4ffe55da0618cdfa341ac88153e8625b3f1 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Mon, 21 Apr 2014 05:24:43 +0000 Subject: queue_kqueue: fixup comments from copy+paste Much of this code was copied from the epoll queue. --- lib/yahns/queue_kqueue.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/yahns/queue_kqueue.rb b/lib/yahns/queue_kqueue.rb index c502de0..ce75793 100644 --- a/lib/yahns/queue_kqueue.rb +++ b/lib/yahns/queue_kqueue.rb @@ -26,7 +26,7 @@ class Yahns::Queue < SleepyPenguin::Kqueue::IO # :nodoc: # flags: QEV_RD/QEV_WR (usually QEV_RD) def queue_add(io, flags) # order is very important here, this thread cannot do anything with - # io once we've issued epoll_ctl() because another thread may use it + # io once we've issued kevent EV_ADD because another thread may use it @fdmap.add(io) fflags = ADD_ONESHOT if flags == QEV_QUIT @@ -54,8 +54,8 @@ class Yahns::Queue < SleepyPenguin::Kqueue::IO # :nodoc: begin kevent(nil, max_events) do |_,_,_,_,_,io| # don't care for flags for now # Note: we absolutely must not do anything with io after - # we've called epoll_ctl on it, io is exclusive to this - # thread only until epoll_ctl is called on it. + # we've called kevent(...,EV_ADD) on it, io is exclusive to this + # thread only until kevent(...,EV_ADD) is called on it. case rv = io.yahns_step when :wait_readable kevent(Kevent[io.fileno, QEV_RD, ADD_ONESHOT, 0, 0, io]) -- cgit v1.2.3-24-ge0c7