lib/yahns/queue_epoll.rb in yahns-1.17.0 vs lib/yahns/queue_epoll.rb in yahns-1.18.0
- old
+ new
@@ -30,9 +30,13 @@
def queue_mod(io, flags)
epoll_ctl(Epoll::CTL_MOD, io, flags)
end
+ def queue_del(io)
+ epoll_ctl(Epoll::CTL_DEL, io, 0)
+ end
+
def thr_init
Thread.current[:yahns_rbuf] = ''.dup
Thread.current[:yahns_fdmap] = @fdmap
Thread.current[:yahns_queue] = self
end