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