webrick.rb

module Sunglass
  module Slave
    class WEBrick
      def initialize(application, port)
        @application = application
        @port = port
        @mutex = Mutex.new
        @condition = ConditionVariable.new
      end

      def start
        @mutex.synchronize do
          Thread.new do
            Rack::Handler::WEBrick.run(@application, webrick_options) { |server| @server = server }
          end

          @condition.wait @mutex
        end
      end

      def stop
        @mutex.synchronize do
          @server.shutdown
          @condition.wait @mutex
        end
      end

      private
        def webrick_options
          {
            :Port => @port,
            :Logger => Logger.new('/dev/null'),
            :AccessLog => [],
            :StartCallback => lambda { @mutex.synchronize { @condition.signal } },
            :StopCallback => lambda { @mutex.synchronize { @condition.signal } },
          }
        end
    end
  end
end