]> source.dussan.org Git - rspamd.git/commitdiff
[Minor] Make names more informative
authorLeftTry <lerest.go@gmail.com>
Sun, 29 Sep 2024 08:07:53 +0000 (14:07 +0600)
committerLeftTry <lerest.go@gmail.com>
Sun, 29 Sep 2024 08:07:53 +0000 (14:07 +0600)
lualib/redis_scripts/ratelimit_check.lua
src/plugins/lua/ratelimit.lua

index f8e34bbf721d86353e484e2f8594c2db827da045..019996c11dbc50e0b2e0a5ea8e280d668a893817 100644 (file)
@@ -31,8 +31,8 @@ local leak_rate = tonumber(KEYS[3])
 local max_burst = tonumber(KEYS[4])
 local prefix = KEYS[1]
 local enable_dynamic = KEYS[7] == 'true'
-local cache_prefix = KEYS[8]
-local max_cache_size = KEYS[9]
+local lfb_cache_prefix = KEYS[8]
+local lfb_max_cache_size = tonumber(KEYS[9])
 local dynr, dynb, leaked = 0, 0, 0
 if not last then
   -- New bucket
@@ -85,8 +85,8 @@ if burst + pending > 0 then
 
   burst = burst + pending
   if burst > 0 and burst > max_burst * dynb then
-    redis.call('ZREMRANGEBYRANK', cache_prefix, 0, -(max_cache_size + 1))
-    redis.call('ZADD', cache_prefix, now, prefix) -- LRU cache is based on timestamps of buckets
+    redis.call('ZREMRANGEBYRANK', lfb_cache_prefix, 0, -(lfb_max_cache_size + 1)) -- Keeping size of lfb cache
+    redis.call('ZADD', lfb_cache_prefix, now, prefix) -- LRU cache is based on timestamps of buckets
 
     return { 1, tostring(burst - pending), tostring(dynr), tostring(dynb), tostring(leaked) }
   end
index c0783eac8ed786643980e4de49b05039fd206470..71ab52b4ffbfcf310229367fcf4d2f936f3d6622 100644 (file)
@@ -41,8 +41,8 @@ local settings = {
   -- Do not check ratelimits for these recipients
   whitelisted_rcpts = { 'postmaster', 'mailer-daemon' },
   prefix = 'RL',
-  cache_prefix = 'RL_cache_prefix',
-  max_cache_size = 30,
+  lfb_cache_prefix = 'RL_cache_prefix', -- Last filled buckets cache prefix
+  lfb_max_cache_size = 30,
   -- If enabled, we apply dynamic rate limiting based on the verdict
   dynamic_rate_limit = false,
   ham_factor_rate = 1.01,
@@ -443,7 +443,7 @@ local function ratelimit_cb(task)
 
     for pr, value in pairs(prefixes) do
       local bucket = value.bucket
-      local rate = (bucket.rate) / 1000.0 -- Leak rate in messages/ms
+      local rate = (bucket.rate) / 1000.0 -- Leak rate in messast filled bucketsages/ms
       local bincr = nrcpt
       if bucket.skip_recipients then
         bincr = 1
@@ -458,7 +458,7 @@ local function ratelimit_cb(task)
           gen_check_cb(pr, bucket, value.name, value.hash),
           { value.hash, tostring(now), tostring(rate), tostring(bucket.burst),
             tostring(settings.expire), tostring(bincr), tostring(dyn_rate_enabled),
-            settings.cache_prefix, settings.max_cache_size })
+            tostring(settings.lfb_cache_prefix), tostring(settings.lfb_max_cache_size) })
     end
   end
 end