1 # -*- encoding: binary -*-
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://cramp.in/],
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
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
23 # {async_sinatra}[http://github.com/raggi/async_sinatra].
25 # For a complete asynchronous framework,
26 # {Cramp}[http://cramp.in/] 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 Rainbows::EventMachine::TryDefer
37 # This model does not implement as streaming "rack.input" which allows
38 # the Rack application to process data as it arrives. This means
39 # "rack.input" will be fully buffered in memory or to a temporary file
40 # before the application is entered.
42 # === RubyGem Requirements
44 # * event_machine 0.12.10
45 module Rainbows::EventMachine
46 autoload :ResponsePipe, 'rainbows/event_machine/response_pipe'
47 autoload :ResponseChunkPipe, 'rainbows/event_machine/response_chunk_pipe'
48 autoload :TryDefer, 'rainbows/event_machine/try_defer'
49 autoload :Client, 'rainbows/event_machine/client'
51 include Rainbows::Base
53 # Cramp (and possibly others) can subclass Rainbows::EventMachine::Client
54 # and provide the :em_client_class option. We /don't/ want to load
55 # Rainbows::EventMachine::Client in the master process since we need
58 case klass = Rainbows::O[:em_client_class]
60 klass.call # e.g.: proc { Cramp::WebSocket::Rainbows }
62 eval(klass.to_s) # Object.const_get won't resolve multi-level paths
63 else # @use should be either :EventMachine or :NeverBlock
64 Rainbows.const_get(@use).const_get(:Client)
68 # runs inside each forked worker, this sits around and waits
69 # for connections and doesn't die until the parent dies (or is
70 # given a INT, QUIT, or TERM signal)
71 def worker_loop(worker) # :nodoc:
72 init_worker_process(worker)
73 server = Rainbows.server
74 server.app.respond_to?(:deferred?) and
75 server.app = TryDefer.new(server.app)
77 # enable them both, should be non-fatal if not supported
80 logger.info "#@use: epoll=#{EM.epoll?} kqueue=#{EM.kqueue?}"
81 client_class = em_client_class
82 max = worker_connections + LISTENERS.size
83 Rainbows::EventMachine::Server.const_set(:MAX, max)
84 Rainbows::EventMachine::Server.const_set(:CL, client_class)
85 Rainbows::EventMachine::Client.const_set(:APP, Rainbows.server.app)
87 conns = EM.instance_variable_get(:@conns) or
88 raise RuntimeError, "EM @conns instance variable not accessible!"
89 Rainbows::EventMachine::Server.const_set(:CUR, conns)
91 EM.next_tick { conns.each_value { |c| client_class === c and c.quit } }
93 EM.add_periodic_timer(1) do
94 EM.stop if ! Rainbows.tick && conns.empty? && EM.reactor_running?
97 EM.watch(s, Rainbows::EventMachine::Server) do |c|
98 c.notify_readable = true
105 require 'rainbows/event_machine/server'