aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2016-12-28 16:41:36 +0000
committerVsevolod Stakhov <vsevolod@highsecure.ru>2016-12-28 16:41:36 +0000
commit10cf293d088c285ece287730a1b62313aae8fba5 (patch)
tree12902073822e1e60da73c48ef37ff8785f622954
parentf93080e713b886f313bf31bd51dd9c397cec8cb1 (diff)
downloadrspamd-10cf293d088c285ece287730a1b62313aae8fba5.tar.gz
rspamd-10cf293d088c285ece287730a1b62313aae8fba5.zip
[Fix] Fix keys names
-rw-r--r--src/plugins/lua/fann_redis.lua10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/plugins/lua/fann_redis.lua b/src/plugins/lua/fann_redis.lua
index d5d27d4da..76ab54062 100644
--- a/src/plugins/lua/fann_redis.lua
+++ b/src/plugins/lua/fann_redis.lua
@@ -556,7 +556,7 @@ local function train_fann(_, ev_base, elt)
false, -- is write
redis_unlock_cb, --callback
'DEL', -- command
- {gen_fann_prefix(elt) .. '_lock'}
+ {gen_fann_prefix(elt) .. '_locked'}
)
if string.match(err, 'NOSCRIPT') then
load_scripts(rspamd_config, ev_base, nil)
@@ -575,7 +575,7 @@ local function train_fann(_, ev_base, elt)
true, -- is write
redis_unlock_cb, --callback
'DEL', -- command
- {gen_fann_prefix(elt) .. '_lock'}
+ {gen_fann_prefix(elt) .. '_locked'}
)
else
rspamd_logger.infox(rspamd_config, 'trained ANN %s: MSE: %s',
@@ -605,7 +605,7 @@ local function train_fann(_, ev_base, elt)
true, -- is write
redis_unlock_cb, --callback
'DEL', -- command
- {gen_fann_prefix(elt) .. '_lock'}
+ {gen_fann_prefix(elt) .. '_locked'}
)
else
-- Decompress and convert to numbers each training vector
@@ -676,7 +676,7 @@ local function train_fann(_, ev_base, elt)
true, -- is write
redis_unlock_cb, --callback
'DEL', -- command
- {gen_fann_prefix(elt) .. '_lock'}
+ {gen_fann_prefix(elt) .. '_locked'}
)
else
-- Decompress and convert to numbers each training vector
@@ -731,7 +731,7 @@ local function train_fann(_, ev_base, elt)
true, -- is write
redis_lock_extend_cb, --callback
'INCRBY', -- command
- {gen_fann_prefix(elt) .. '_lock', '30'}
+ {gen_fann_prefix(elt) .. '_locked', '30'}
)
else
return false -- do not plan any more updates