]> source.dussan.org Git - rspamd.git/commitdiff
[Minor] Lua_util: More caching tuning
authorVsevolod Stakhov <vsevolod@highsecure.ru>
Mon, 19 Aug 2019 15:27:49 +0000 (16:27 +0100)
committerVsevolod Stakhov <vsevolod@highsecure.ru>
Mon, 19 Aug 2019 15:27:49 +0000 (16:27 +0100)
lualib/lua_util.lua

index 363ce4a653b4a2f488b5f2fe6133d3831d4e0625..9bc42fd62efd7127a1e2accac58dcc4b80462b56 100644 (file)
@@ -636,20 +636,18 @@ exports.override_defaults = override_defaults
 exports.filter_specific_urls = function (urls, params)
   local cache_key
 
-  if params.prefix then
-    cache_key = params.prefix
-  else
-    cache_key = string.format('sp_urls_%d%s', params.limit,
-        tostring(params.need_emails or false))
-  end
-
-  if params.task then
+  if params.task and not params.no_cache then
+    if params.prefix then
+      cache_key = params.prefix
+    else
+      cache_key = string.format('sp_urls_%d%s', params.limit,
+          tostring(params.need_emails or false))
+    end
     local cached = params.task:cache_get(cache_key)
 
     if cached then
       return cached
     end
-
   end
 
   if not urls then return {} end
@@ -657,7 +655,7 @@ exports.filter_specific_urls = function (urls, params)
   if params.filter then urls = fun.totable(fun.filter(params.filter, urls)) end
 
   if #urls <= params.limit and #urls <= params.esld_limit then
-    if params.task then
+    if params.task and not params.no_cache then
       params.task:cache_set(cache_key, urls)
     end
 
@@ -742,7 +740,9 @@ exports.filter_specific_urls = function (urls, params)
 
     until limit <= 0 or not item_found
 
-    params.task:cache_set(cache_key, urls)
+    if params.task and not params.no_cache then
+      params.task:cache_set(cache_key, urls)
+    end
     return res
   end
 
@@ -756,7 +756,9 @@ exports.filter_specific_urls = function (urls, params)
       end
     end
 
-    params.task:cache_set(cache_key, urls)
+    if params.task and not params.no_cache then
+      params.task:cache_set(cache_key, urls)
+    end
     return res
   end
 
@@ -785,7 +787,7 @@ exports.filter_specific_urls = function (urls, params)
     end
   end
 
-  if params.task then
+  if params.task and not params.no_cache then
     params.task:cache_set(cache_key, urls)
   end
 
@@ -817,6 +819,7 @@ exports.extract_specific_urls = function(params_or_task, lim, need_emails, filte
     filter = nil,
     prefix = nil,
     ignore_redirected = false,
+    no_cache = false,
   }
 
   local params