lib/rainbows/epoll.rb

   1 # -*- encoding: binary -*-
   2 # :enddoc:
   3 require 'sleepy_penguin'
   4 require 'sendfile'
   5
   6 # Edge-triggered epoll concurrency model.  This is extremely unfair
   7 # and optimized for throughput at the expense of fairness
   8 module Rainbows::Epoll
   9   include Rainbows::Base
  10   autoload :Server, 'rainbows/epoll/server'
  11   autoload :Client, 'rainbows/epoll/client'
  12   autoload :ResponsePipe, 'rainbows/epoll/response_pipe'
  13   autoload :ResponseChunkPipe, 'rainbows/epoll/response_chunk_pipe'
  14
  15   def init_worker_process(worker)
  16     super
  17     Rainbows::Epoll.const_set :EP, SleepyPenguin::Epoll.new
  18     trap(:QUIT) { Rainbows.quit!; EP.close unless EP.closed? }
  19     Rainbows::Client.__send__ :include, Client
  20   end
  21
  22   def worker_loop(worker) # :nodoc:
  23     init_worker_process(worker)
  24     Server.run
  25   end
  26 end