From 776ea1090fb9ba4353035d4983cf1926a67b3294 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jos=C3=A9=20Valim?= Date: Mon, 21 May 2012 21:01:02 +0200 Subject: Revert "Merge pull request #6425 from pinetops/resolver_concurrency_fix" This reverts commit 254c04286c5916ae7f91eb6e173b312e7a74e364, reversing changes made to 513a0525c24c2944630acfa465b22cd2f4601adf. --- actionpack/lib/action_view/template/resolver.rb | 87 ++++++------------------- 1 file changed, 19 insertions(+), 68 deletions(-) (limited to 'actionpack/lib/action_view/template/resolver.rb') diff --git a/actionpack/lib/action_view/template/resolver.rb b/actionpack/lib/action_view/template/resolver.rb index 8f87d6da8b..fa2038f78d 100644 --- a/actionpack/lib/action_view/template/resolver.rb +++ b/actionpack/lib/action_view/template/resolver.rb @@ -2,7 +2,6 @@ require "pathname" require "active_support/core_ext/class" require "active_support/core_ext/class/attribute_accessors" require "action_view/template" -require "thread" module ActionView # = Action View Resolver @@ -25,64 +24,6 @@ module ActionView end end - # Threadsafe template cache - class Cache #:nodoc: - class CacheEntry - attr_accessor :templates - - delegate :synchronize, :to => "@mutex" - - def initialize - @mutex = Mutex.new - end - end - - def initialize - @data = Hash.new { |h1,k1| h1[k1] = Hash.new { |h2,k2| - h2[k2] = Hash.new { |h3,k3| h3[k3] = Hash.new { |h4,k4| h4[k4] = {} } } } } - @mutex = Mutex.new - end - - # Cache the templates returned by the block - def cache(key, name, prefix, partial, locals) - cache_entry = nil - - # first obtain a lock on the main data structure to create the cache entry - @mutex.synchronize do - cache_entry = @data[key][name][prefix][partial][locals] ||= CacheEntry.new - end - - # then to avoid a long lasting global lock, obtain a more granular lock - # on the CacheEntry itself - cache_entry.synchronize do - if Resolver.caching? - # all templates are cached forever the first time they are accessed - cache_entry.templates ||= yield - else - # templates are still cached, but are only returned if they are - # all still current - fresh = yield - - mtime = cache_entry.templates && cache_entry.templates.map(&:updated_at).max - - newer = !mtime || fresh.empty? || fresh.any? { |t| t.updated_at > mtime } - - if newer - cache_entry.templates = fresh - else - cache_entry.templates - end - end - end - end - - def clear - @mutex.synchronize do - @data.clear - end - end - end - cattr_accessor :caching self.caching = true @@ -91,11 +32,12 @@ module ActionView end def initialize - @cache = Cache.new + @cached = Hash.new { |h1,k1| h1[k1] = Hash.new { |h2,k2| + h2[k2] = Hash.new { |h3,k3| h3[k3] = Hash.new { |h4,k4| h4[k4] = {} } } } } end def clear_cache - @cache.clear + @cached.clear end # Normalizes the arguments and passes it on to find_template. @@ -123,18 +65,27 @@ module ActionView # Handles templates caching. If a key is given and caching is on # always check the cache before hitting the resolver. Otherwise, - # it always hits the resolver but if the key is present, check if the - # resolver is fresher before returning it. + # it always hits the resolver but check if the resolver is fresher + # before returning it. def cached(key, path_info, details, locals) #:nodoc: name, prefix, partial = path_info locals = locals.map { |x| x.to_s }.sort! - if key - @cache.cache(key, name, prefix, partial, locals) do - decorate(yield, path_info, details, locals) - end + if key && caching? + @cached[key][name][prefix][partial][locals] ||= decorate(yield, path_info, details, locals) else - decorate(yield, path_info, details, locals) + fresh = decorate(yield, path_info, details, locals) + return fresh unless key + + scope = @cached[key][name][prefix][partial] + cache = scope[locals] + mtime = cache && cache.map(&:updated_at).max + + if !mtime || fresh.empty? || fresh.any? { |t| t.updated_at > mtime } + scope[locals] = fresh + else + cache + end end end -- cgit v1.2.3