StreamFile and TmpIO attempt expiry on EMFILE/ENFILE

This should help prevent some errors from popping up.
Obviously, we cannot spend too long doing this inside
a worker thread.

1 files changed, 6 insertions, 1 deletions

diff --git a/lib/yahns/queue_epoll.rb b/lib/yahns/queue_epoll.rb
index c4a80a3..397df7a 100644
--- a/lib/yahns/queue_epoll.rb
+++ b/lib/yahns/queue_epoll.rb
@@ -22,10 +22,15 @@ class Yahns::Queue < SleepyPenguin::Epoll::IO # :nodoc:
     epoll_ctl(Epoll::CTL_ADD, io, flags)
   end
 
+  def thr_init
+    Thread.current[:yahns_rbuf] = ""
+    Thread.current[:yahns_fdmap] = @fdmap
+  end
+
   # returns an array of infinitely running threads
   def worker_thread(logger, max_events)
     Thread.new do
-      Thread.current[:yahns_rbuf] = ""
+      thr_init
       begin
         epoll_wait(max_events) do |_, io| # don't care for flags for now
           case rv = io.yahns_step