aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2015-09-28 18:41:22 +0100
committerVsevolod Stakhov <vsevolod@highsecure.ru>2015-09-28 18:41:22 +0100
commit352e35b245ba850cbb39f0fc07777e727f99484a (patch)
tree2163c422462cc14ad039f1ce0306e368a99d6849
parent5fe7a9e322f0a49ce22b8e6df4b4b0d70b926d7b (diff)
downloadrspamd-352e35b245ba850cbb39f0fc07777e727f99484a.tar.gz
rspamd-352e35b245ba850cbb39f0fc07777e727f99484a.zip
Preserve expired fuzzy hashes counter.
-rw-r--r--src/fuzzy_storage.c7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/fuzzy_storage.c b/src/fuzzy_storage.c
index 016f0c6e0..159570c1e 100644
--- a/src/fuzzy_storage.c
+++ b/src/fuzzy_storage.c
@@ -265,12 +265,17 @@ sync_callback (gint fd, short what, void *arg)
struct rspamd_worker *worker = (struct rspamd_worker *)arg;
struct rspamd_fuzzy_storage_ctx *ctx;
gdouble next_check;
+ guint64 old_expired, new_expired;
ctx = worker->ctx;
/* Call backend sync */
+ old_expired = rspamd_fuzzy_backend_expired (ctx->backend);
rspamd_fuzzy_backend_sync (ctx->backend, ctx->expire, TRUE);
+ new_expired = rspamd_fuzzy_backend_expired (ctx->backend);
- server_stat->fuzzy_hashes_expired = rspamd_fuzzy_backend_expired (ctx->backend);
+ if (old_expired < new_expired) {
+ server_stat->fuzzy_hashes_expired += new_expired - old_expired;
+ }
/* Timer event */
event_del (&tev);