diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2018-07-02 12:30:08 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2018-07-02 12:30:08 +0100 |
| commit | 1812d38cb85eb3766e1ed0adbf75b57475af6b0e (patch) | |
| tree | 4cb04b19f6bb7469b3269b2a5ef44df4d6bb95b6 /src/libserver/fuzzy_backend_redis.c | |
| parent | e03e1d6bfbd976ec23af197d0d88ccff1933e430 (diff) | |
| download | rspamd-1812d38cb85eb3766e1ed0adbf75b57475af6b0e.tar.gz rspamd-1812d38cb85eb3766e1ed0adbf75b57475af6b0e.zip | |
[Feature] Distinguish IP failures from connection failures
Diffstat (limited to 'src/libserver/fuzzy_backend_redis.c')
| -rw-r--r-- | src/libserver/fuzzy_backend_redis.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/libserver/fuzzy_backend_redis.c b/src/libserver/fuzzy_backend_redis.c index 06f100132..d25f057ed 100644 --- a/src/libserver/fuzzy_backend_redis.c +++ b/src/libserver/fuzzy_backend_redis.c @@ -467,7 +467,7 @@ rspamd_fuzzy_redis_shingles_callback (redisAsyncContext *c, gpointer r, msg_err_redis_session ("error getting shingles: %s", c->errstr); } - rspamd_upstream_fail (session->up); + rspamd_upstream_fail (session->up, FALSE); } rspamd_fuzzy_redis_session_dtor (session, FALSE); @@ -606,7 +606,7 @@ rspamd_fuzzy_redis_check_callback (redisAsyncContext *c, gpointer r, msg_err_redis_session ("error getting hashes: %s", c->errstr); } - rspamd_upstream_fail (session->up); + rspamd_upstream_fail (session->up, FALSE); } rspamd_fuzzy_redis_session_dtor (session, FALSE); @@ -674,7 +674,7 @@ rspamd_fuzzy_backend_check_redis (struct rspamd_fuzzy_backend *bk, rspamd_inet_address_get_port (addr)); if (session->ctx == NULL) { - rspamd_upstream_fail (up); + rspamd_upstream_fail (up, TRUE); rspamd_fuzzy_redis_session_dtor (session, TRUE); if (cb) { @@ -744,7 +744,7 @@ rspamd_fuzzy_redis_count_callback (redisAsyncContext *c, gpointer r, msg_err_redis_session ("error getting count: %s", c->errstr); } - rspamd_upstream_fail (session->up); + rspamd_upstream_fail (session->up, FALSE); } rspamd_fuzzy_redis_session_dtor (session, FALSE); @@ -798,7 +798,7 @@ rspamd_fuzzy_backend_count_redis (struct rspamd_fuzzy_backend *bk, rspamd_inet_address_get_port (addr)); if (session->ctx == NULL) { - rspamd_upstream_fail (up); + rspamd_upstream_fail (up, TRUE); rspamd_fuzzy_redis_session_dtor (session, TRUE); if (cb) { @@ -866,7 +866,7 @@ rspamd_fuzzy_redis_version_callback (redisAsyncContext *c, gpointer r, msg_err_redis_session ("error getting version: %s", c->errstr); } - rspamd_upstream_fail (session->up); + rspamd_upstream_fail (session->up, FALSE); } rspamd_fuzzy_redis_session_dtor (session, FALSE); @@ -921,7 +921,7 @@ rspamd_fuzzy_backend_version_redis (struct rspamd_fuzzy_backend *bk, rspamd_inet_address_get_port (addr)); if (session->ctx == NULL) { - rspamd_upstream_fail (up); + rspamd_upstream_fail (up, FALSE); rspamd_fuzzy_redis_session_dtor (session, TRUE); if (cb) { @@ -1272,7 +1272,7 @@ rspamd_fuzzy_redis_update_callback (redisAsyncContext *c, gpointer r, msg_err_redis_session ("error sending update to redis: %s", c->errstr); } - rspamd_upstream_fail (session->up); + rspamd_upstream_fail (session->up, FALSE); } rspamd_fuzzy_redis_session_dtor (session, FALSE); @@ -1382,7 +1382,7 @@ rspamd_fuzzy_backend_update_redis (struct rspamd_fuzzy_backend *bk, rspamd_inet_address_get_port (addr)); if (session->ctx == NULL) { - rspamd_upstream_fail (up); + rspamd_upstream_fail (up, TRUE); rspamd_fuzzy_redis_session_dtor (session, TRUE); if (cb) { |