writer_thread_spawn: factor out Client.quit
[rainbows.git] / lib / rainbows / event_machine.rb
blobb226cabb31818cfa509ed31aa0c22b012d71ce53
1 # -*- encoding: binary -*-
2 require 'eventmachine'
3 EM::VERSION >= '0.12.10' or abort 'eventmachine 0.12.10 is required'
5 # Implements a basic single-threaded event model with
6 # {EventMachine}[http://rubyeventmachine.com/].  It is capable of
7 # handling thousands of simultaneous client connections, but with only
8 # a single-threaded app dispatch.  It is suited for slow clients,
9 # and can work with slow applications via asynchronous libraries such as
10 # {async_sinatra}[http://github.com/raggi/async_sinatra],
11 # {Cramp}[http://m.onkey.org/2010/1/7/introducing-cramp],
12 # and {rack-fiber_pool}[http://github.com/mperham/rack-fiber_pool].
14 # It does not require your Rack application to be thread-safe,
15 # reentrancy is only required for the DevFdResponse body
16 # generator.
18 # Compatibility: Whatever \EventMachine ~> 0.12.10 and Unicorn both
19 # support, currently Ruby 1.8/1.9.
21 # This model is compatible with users of "async.callback" in the Rack
22 # environment such as
23 # {async_sinatra}[http://github.com/raggi/async_sinatra].
25 # For a complete asynchronous framework,
26 # {Cramp}[http://m.onkey.org/2010/1/7/introducing-cramp] is fully
27 # supported when using this concurrency model.
29 # This model is fully-compatible with
30 # {rack-fiber_pool}[http://github.com/mperham/rack-fiber_pool]
31 # which allows each request to run inside its own \Fiber after
32 # all request processing is complete.
34 # Merb (and other frameworks/apps) supporting +deferred?+ execution as
35 # documented at http://brainspl.at/articles/2008/04/18/deferred-requests-with-merb-ebb-and-thin
36 # will also get the ability to conditionally defer request processing
37 # to a separate thread.
39 # This model does not implement as streaming "rack.input" which allows
40 # the Rack application to process data as it arrives.  This means
41 # "rack.input" will be fully buffered in memory or to a temporary file
42 # before the application is entered.
43 module Rainbows::EventMachine
44   autoload :ResponsePipe, 'rainbows/event_machine/response_pipe'
45   autoload :ResponseChunkPipe, 'rainbows/event_machine/response_chunk_pipe'
46   autoload :TryDefer, 'rainbows/event_machine/try_defer'
48   include Rainbows::Base
50   def init_worker_process(worker) # :nodoc:
51     Rainbows::Response.setup(Rainbows::EventMachine::Client)
52     super
53   end
55   # runs inside each forked worker, this sits around and waits
56   # for connections and doesn't die until the parent dies (or is
57   # given a INT, QUIT, or TERM signal)
58   def worker_loop(worker) # :nodoc:
59     init_worker_process(worker)
60     G.server.app.respond_to?(:deferred?) and
61       G.server.app = Rainbows::EventMachine::TryDefer[G.server.app]
63     # enable them both, should be non-fatal if not supported
64     EM.epoll
65     EM.kqueue
66     logger.info "#@use: epoll=#{EM.epoll?} kqueue=#{EM.kqueue?}"
67     client_class = Rainbows.const_get(@use).const_get(:Client)
68     max = worker_connections + LISTENERS.size
69     Rainbows::EventMachine::Server.const_set(:MAX, max)
70     Rainbows::EventMachine::Server.const_set(:CL, client_class)
71     client_class.const_set(:APP, G.server.app)
72     Rainbows::EvCore.setup
73     EM.run {
74       conns = EM.instance_variable_get(:@conns) or
75         raise RuntimeError, "EM @conns instance variable not accessible!"
76       Rainbows::EventMachine::Server.const_set(:CUR, conns)
77       EM.add_periodic_timer(1) do
78         unless G.tick
79           conns.each_value { |c| client_class === c and c.quit }
80           EM.stop if conns.empty? && EM.reactor_running?
81         end
82       end
83       LISTENERS.map! do |s|
84         EM.watch(s, Rainbows::EventMachine::Server) do |c|
85           c.notify_readable = true
86         end
87       end
88     }
89   end
90 end
91 # :enddoc:
92 require 'rainbows/event_machine/client'
93 require 'rainbows/event_machine/server'