Contents

#!/usr/bin/env ruby
#
# An example application using our patched Thin and EventMachine. You
# can obtain these from:
#
#   https://github.com/stripe/thin.git, and
#   https://github.com/stripe/eventmachine.git

require 'rubygems'
require 'einhorn'

require 'eventmachine-le'
require 'thin'
require 'thin/attach_socket'

class App
  def initialize(id)
    @id = id
  end

  def call(env)
    return [200, {}, "[#{$$}] From server instance #{@id}: Got your request!\n"]
  end
end

def einhorn_main
  puts "Called with #{ARGV.inspect}"
  fd_count = Einhorn::Worker.einhorn_fd_count

  unless fd_count > 0
    raise "Need to call with at least one bound socket. Try running 'einhorn -b 127.0.0.1:5000,r,n -b 127.0.0.1:5001,r,n #{$0}' and then running 'curl 127.0.0.1:5000' or 'curl 127.0.0.1:5001'"
  end

  Einhorn::Worker.graceful_shutdown do
    puts "#{$$} is now exiting..."
    exit(0)
  end
  Einhorn::Worker.ack!

  EventMachine.run do
    (0...fd_count).each do |i|
      sock = Einhorn::Worker.socket!(i)
      srv = Thin::Server.new(App.new(i),
        :backend => Thin::Backends::AttachSocket,
        :socket => IO.for_fd(sock))
      srv.start
    end
  end
end

if $0 == __FILE__
  einhorn_main
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
einhorn-0.8.2	example/thin_example
einhorn-0.7.4	example/thin_example
einhorn-0.7.3	example/thin_example
einhorn-0.7.2	example/thin_example
einhorn-0.7.1	example/thin_example
einhorn-0.7.0	example/thin_example
einhorn-0.6.5	example/thin_example
einhorn-0.6.4	example/thin_example
einhorn-0.6.3	example/thin_example
einhorn-0.6.2	example/thin_example
einhorn-0.6.1	example/thin_example
einhorn-0.6.0	example/thin_example
einhorn-0.5.7	example/thin_example