1 files changed, 42 insertions, 0 deletions
diff --git a/lib/rainbows/rev/core.rb b/lib/rainbows/rev/core.rb
new file mode 100644
index 0000000..0d1add5
--- /dev/null
+++ b/lib/rainbows/rev/core.rb
@@ -0,0 +1,42 @@
+# -*- encoding: binary -*-
+require 'rev'
+Rev::VERSION >= '0.3.0' or abort 'rev >= 0.3.0 is required'
+require 'rainbows/rev/heartbeat'
+
+module Rainbows
+  module Rev
+    class Server < ::Rev::IO
+      G = Rainbows::G
+      LOOP = ::Rev::Loop.default
+      # CL and MAX will be defined in the corresponding worker loop
+
+      def on_readable
+        return if G.cur >= MAX
+        begin
+          CL.new(@_io.accept_nonblock).attach(LOOP)
+        rescue Errno::EAGAIN, Errno::ECONNABORTED
+        end
+      end
+    end # class Server
+
+    module Core
+
+      # runs inside each forked worker, this sits around and waits
+      # for connections and doesn't die until the parent dies (or is
+      # given a INT, QUIT, or TERM signal)
+      def worker_loop(worker)
+        init_worker_process(worker)
+        mod = self.class.const_get(@use)
+        client = mod.const_get(:Client)
+        client.const_set(:APP, G.server.app)
+        Server.const_set(:MAX, G.server.worker_connections)
+        Server.const_set(:CL, client)
+        rloop = ::Rev::Loop.default
+        Heartbeat.new(1, true).attach(rloop)
+        LISTENERS.map! { |s| Server.new(s).attach(rloop) }
+        rloop.run
+      end
+
+    end # module Core
+  end # module Rev
+end # module Rainbows