If only life was that simple (it didnt help)

git-svn-id: http://svn-commit.rubyonrails.org/rails/trunk@5658 5ecf4fe2-1ee6-0310-87b1-e25e094e27de
This commit is contained in:
David Heinemeier Hansson 2006-12-01 05:56:51 +00:00
parent e8eb743ba6
commit 2e2bf2d149
5 changed files with 25 additions and 10 deletions

View File

@ -87,6 +87,14 @@ module ActiveRecord
end
end
# Clears the cache which maps classes
def clear_reloadable_connections!
@@active_connections.each do |name, conn|
conn.disconnect! if conn.supports_reloading?
@@active_connections.delete(name)
end
end
# Verify active connections.
def verify_active_connections! #:nodoc:
if @@allow_concurrency

View File

@ -79,6 +79,12 @@ module ActiveRecord
@active = false
end
# Returns true if its safe to reload the connection between requests for development mode.
# This is not the case for Ruby/MySQL and it's not necessary for any adapters except SQLite.
def supports_reloading?
false
end
# Lazily verify this connection, calling +active?+ only if it hasn't
# been called for +timeout+ seconds.
def verify!(timeout)

View File

@ -102,6 +102,10 @@ module ActiveRecord
true
end
def supports_reloading?
true
end
def supports_count_distinct? #:nodoc:
sqlite_version >= '3.2.6'
end

View File

@ -1173,14 +1173,8 @@ class << Mysql
def finalizer(net)
proc {
begin
net.clear
net.write Mysql::COM_QUIT.chr
net.close
rescue Error => error
# Swallow lost connection errors if connection is already closed.
raise unless error.errno == Error::CR_SERVER_LOST
end
net.clear
net.write Mysql::COM_QUIT.chr
}
end

View File

@ -62,7 +62,7 @@ class Dispatcher
Class.remove_class(*Reloadable.reloadable_classes)
end
ActiveRecord::Base.clear_active_connections! if defined?(ActiveRecord)
ActiveRecord::Base.clear_reloadable_connections! if defined?(ActiveRecord)
end
# Add a preparation callback. Preparation callbacks are run before every
@ -76,13 +76,16 @@ class Dispatcher
def to_prepare(identifier = nil, &block)
unless identifier.nil?
callback = preparation_callbacks.detect { |ident, _| ident == identifier }
if callback # Already registered: update the existing callback
callback[-1] = block
return
end
end
preparation_callbacks << [identifier, block]
nil
return
end
private