Sha256: fb714f1487ec539c1e862d7044fcb8ab7f6958d289735c71ff8c58f0e0bb360b
Contents?: true
Size: 1.14 KB
Versions: 15
Compression:
Stored size: 1.14 KB
Contents
module Waterpig
class DeadbeatConnectionRelease
def initialize(app)
@app = app
end
#This is a brittle hack for what appears to be a bug in ActiveRecord 4:
#connections aren't being properly released after their owning threads die
def call(env)
response = @app.call(env)
response[2] = ::Rack::BodyProxy.new(response[2]) do
ActiveRecord::Base.connection_handler.connection_pool_list.each do |pool|
reservers = pool.instance_variable_get("@reserved_connections").keys
deadbeats = reservers - Thread.list.map(&:object_id)
Rails.logger.info{ "Releasing connections held by these no-longer-living Threads: #{deadbeats}" } unless deadbeats.empty?
deadbeats.each do |deadbeat_id|
pool.release_connection(deadbeat_id)
end
end
end
response
rescue Object => ex
require 'pp'
Rails.logger.fatal "Problem responding to request in test"
Rails.logger.fatal [ex.class, ex.message, ex.backtrace].join("\n")
Rails.logger.fatal env.pretty_inspect
Rails.logger.fatal response.pretty_inspect
raise
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems