Contents

require 'thread'

module Rack
  class Lock
    class Proxy < Struct.new(:target, :mutex) # :nodoc:
      def each
        target.each { |x| yield x }
      end

      def close
        target.close if target.respond_to?(:close)
      ensure
        mutex.unlock
      end

      def to_path
        target.to_path
      end

      def respond_to?(sym)
        sym.to_sym == :close || target.respond_to?(sym)
      end
    end

    FLAG = 'rack.multithread'.freeze

    def initialize(app, mutex = Mutex.new)
      @app, @mutex = app, mutex
    end

    def call(env)
      old, env[FLAG] = env[FLAG], false
      @mutex.lock
      response = @app.call(env)
      response[2] = Proxy.new(response[2], @mutex)
      response
    rescue Exception
      @mutex.unlock
      raise
    ensure
      env[FLAG] = old
    end
  end
end

Version data entries

5 entries across 5 versions & 3 rubygems

Version	Path
search_biomodel-1.0.0	search_biomodel/ruby/1.8/gems/rack-1.3.0/lib/rack/lock.rb
rack-1.3.0	lib/rack/lock.rb
rack-1.3.0.beta2	lib/rack/lock.rb
rack-1.3.0.beta	lib/rack/lock.rb
edgar-rack-1.2.1	lib/rack/lock.rb