]> git.ipfire.org Git - thirdparty/rspamd.git/commitdiff
Update neural_save_unlock.lua 5376/head
authorDmitriy Alekseev <1865999+dragoangel@users.noreply.github.com>
Fri, 7 Mar 2025 14:02:32 +0000 (15:02 +0100)
committerGitHub <noreply@github.com>
Fri, 7 Mar 2025 14:02:32 +0000 (15:02 +0100)
lualib/redis_scripts/neural_save_unlock.lua

index bb5f69531b345bcb655fe2b5aac2fb1c1edaa15f..7ea7dc2e58a61eb4293312b0514d51acebfab3d9 100644 (file)
 local now = tonumber(KEYS[6])
 redis.call('ZADD', KEYS[2], now, KEYS[4])
 redis.call('HSET', KEYS[1], 'ann', KEYS[3])
-redis.call('DEL', KEYS[1] .. '_spam_set')
-redis.call('DEL', KEYS[1] .. '_ham_set')
-redis.call('HDEL', KEYS[1], 'lock')
-redis.call('HDEL', KEYS[7], 'lock')
-redis.call('EXPIRE', KEYS[1], tonumber(KEYS[5]))
-redis.call('EXPIRE', KEYS[1] .. '_spam_set', tonumber(KEYS[5]))
-redis.call('EXPIRE', KEYS[1] .. '_ham_set', tonumber(KEYS[5]))
 redis.call('HSET', KEYS[1], 'roc_thresholds', KEYS[8])
 if KEYS[9] then
   redis.call('HSET', KEYS[1], 'pca', KEYS[9])
 end
+redis.call('HDEL', KEYS[1], 'lock')
+redis.call('HDEL', KEYS[7], 'lock')
+redis.call('EXPIRE', KEYS[1], tonumber(KEYS[5]))
+ -- expire in 10m, to not face race condition with other rspamd replicas refill deleted keys
+redis.call('EXPIRE', KEYS[7] .. '_spam_set', 600)
+redis.call('EXPIRE', KEYS[7] .. '_ham_set', 600)
 return 1