aboutsummaryrefslogtreecommitdiffstats
path: root/src/fuzzy_storage.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2014-12-20 16:47:30 +0000
committerVsevolod Stakhov <vsevolod@highsecure.ru>2014-12-20 16:47:30 +0000
commita512d4ada24bef10f6c550fcca6599c5bb2003c2 (patch)
treea69285ee89706aa8b6bd59240e7e46374696b6e6 /src/fuzzy_storage.c
parent084e2e2a3906c0b3302402fcc4a21f1e0baaa618 (diff)
downloadrspamd-a512d4ada24bef10f6c550fcca6599c5bb2003c2.tar.gz
rspamd-a512d4ada24bef10f6c550fcca6599c5bb2003c2.zip
Restore expired/count statistics.
Diffstat (limited to 'src/fuzzy_storage.c')
-rw-r--r--src/fuzzy_storage.c9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/fuzzy_storage.c b/src/fuzzy_storage.c
index 921f17964..7b3c58c43 100644
--- a/src/fuzzy_storage.c
+++ b/src/fuzzy_storage.c
@@ -222,6 +222,7 @@ rspamd_fuzzy_process_command (struct fuzzy_session *session)
rep.value = 403;
rep.prob = 0.0;
}
+ server_stat->fuzzy_hashes = rspamd_fuzzy_backend_count (session->ctx->backend);
}
rspamd_fuzzy_write_reply (session, &rep);
@@ -324,7 +325,9 @@ sync_callback (gint fd, short what, void *arg)
evtimer_add (&tev, &tmv);
/* Call backend sync */
- rspamd_fuzzy_backend_sync (ctx->backend);
+ rspamd_fuzzy_backend_sync (ctx->backend, ctx->expire);
+
+ server_stat->fuzzy_hashes_expired = rspamd_fuzzy_backend_expired (ctx->backend);
}
gpointer
@@ -418,6 +421,8 @@ start_fuzzy (struct rspamd_worker *worker)
exit (EXIT_FAILURE);
}
+ server_stat->fuzzy_hashes = rspamd_fuzzy_backend_count (ctx->backend);
+
/* Timer event */
evtimer_set (&tev, sync_callback, worker);
event_base_set (ctx->ev_base, &tev);
@@ -444,7 +449,7 @@ start_fuzzy (struct rspamd_worker *worker)
event_base_loop (ctx->ev_base, 0);
- rspamd_fuzzy_backend_sync (ctx->backend);
+ rspamd_fuzzy_backend_sync (ctx->backend, ctx->expire);
rspamd_fuzzy_backend_close (ctx->backend);
rspamd_log_close (rspamd_main->logger);
exit (EXIT_SUCCESS);