From: Vsevolod Stakhov Date: Fri, 6 Apr 2018 08:58:03 +0000 (+0100) Subject: [Minor] Some stats logic update for the new schema X-Git-Tag: 1.7.3~24 X-Git-Url: https://source.dussan.org/?a=commitdiff_plain;h=fe180dd5d14574e013e6e5d75502d9da5640863e;p=rspamd.git [Minor] Some stats logic update for the new schema --- diff --git a/src/libstat/backends/redis_backend.c b/src/libstat/backends/redis_backend.c index 121162fc8..68da6bc89 100644 --- a/src/libstat/backends/redis_backend.c +++ b/src/libstat/backends/redis_backend.c @@ -745,7 +745,7 @@ rspamd_redis_stat_learns (redisAsyncContext *c, gpointer r, gpointer priv) rspamd_strtoul (reply->str, reply->len, &num); } - obj = (ucl_object_t *)ucl_object_lookup (cbdata->cur, "revision"); + obj = (ucl_object_t *) ucl_object_lookup (cbdata->cur, "revision"); if (obj) { obj->value.iv += num; } @@ -852,17 +852,26 @@ rspamd_redis_stat_keys (redisAsyncContext *c, gpointer r, gpointer priv) else { learned_key = "learns_ham"; } + redisAsyncCommand (cbdata->redis, + rspamd_redis_stat_learns, + cbdata, + "HGET %s %s", + k, learned_key); + cbdata->inflight += 1; + } + else { + redisAsyncCommand (cbdata->redis, + rspamd_redis_stat_key, + cbdata, + "HLEN %s", + k); + redisAsyncCommand (cbdata->redis, + rspamd_redis_stat_learns, + cbdata, + "HGET %s %s", + k, learned_key); + cbdata->inflight += 2; } - - redisAsyncCommand (cbdata->redis, rspamd_redis_stat_key, - cbdata, - "HLEN %s", - k); - redisAsyncCommand (cbdata->redis, rspamd_redis_stat_learns, - cbdata, - "HGET %s %s", - k, learned_key); - cbdata->inflight += 2; } } }