aboutsummaryrefslogtreecommitdiffstats
path: root/src/libserver/fuzzy_backend_redis.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2018-07-05 13:49:12 +0100
committerVsevolod Stakhov <vsevolod@highsecure.ru>2018-07-05 13:49:12 +0100
commit72f2f16245dbbe2994f44b247114ceb07c42810e (patch)
tree641ae569f8872f07a5b97a5bae20f8a7d566a60c /src/libserver/fuzzy_backend_redis.c
parent7c5d79db90db646cdaef6430482ad8e7dc530f39 (diff)
downloadrspamd-72f2f16245dbbe2994f44b247114ceb07c42810e.tar.gz
rspamd-72f2f16245dbbe2994f44b247114ceb07c42810e.zip
[Feature] Add logic to deduplicate updates queue
Diffstat (limited to 'src/libserver/fuzzy_backend_redis.c')
-rw-r--r--src/libserver/fuzzy_backend_redis.c6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/libserver/fuzzy_backend_redis.c b/src/libserver/fuzzy_backend_redis.c
index 550e76f6f..89bc6728f 100644
--- a/src/libserver/fuzzy_backend_redis.c
+++ b/src/libserver/fuzzy_backend_redis.c
@@ -1191,6 +1191,9 @@ rspamd_fuzzy_update_append_command (struct rspamd_fuzzy_backend *bk,
return FALSE;
}
}
+ else if (cmd->cmd == FUZZY_DUP) {
+ /* Ignore */
+ }
else {
g_assert_not_reached ();
}
@@ -1305,6 +1308,9 @@ rspamd_fuzzy_update_append_command (struct rspamd_fuzzy_backend *bk,
}
}
}
+ else if (cmd->cmd == FUZZY_DUP) {
+ /* Ignore */
+ }
else {
g_assert_not_reached ();
}