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/rspamd_proxy.c | |
| parent | e03e1d6bfbd976ec23af197d0d88ccff1933e430 (diff) | |
| download | rspamd-1812d38cb85eb3766e1ed0adbf75b57475af6b0e.tar.gz rspamd-1812d38cb85eb3766e1ed0adbf75b57475af6b0e.zip | |
[Feature] Distinguish IP failures from connection failures
Diffstat (limited to 'src/rspamd_proxy.c')
| -rw-r--r-- | src/rspamd_proxy.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rspamd_proxy.c b/src/rspamd_proxy.c index 1d4324bdc..4af5ee5f4 100644 --- a/src/rspamd_proxy.c +++ b/src/rspamd_proxy.c @@ -1308,7 +1308,7 @@ proxy_backend_mirror_error_handler (struct rspamd_http_connection *conn, GError bk_conn->err = rspamd_mempool_strdup (session->pool, err->message); } - rspamd_upstream_fail (bk_conn->up); + rspamd_upstream_fail (bk_conn->up, FALSE); proxy_backend_close_connection (bk_conn); REF_RELEASE (bk_conn->s); @@ -1384,7 +1384,7 @@ proxy_open_mirror_connections (struct rspamd_proxy_session *session) if (bk_conn->backend_sock == -1) { msg_err_session ("cannot connect upstream for %s", m->name); - rspamd_upstream_fail (bk_conn->up); + rspamd_upstream_fail (bk_conn->up, TRUE); continue; } @@ -1505,7 +1505,7 @@ proxy_backend_master_error_handler (struct rspamd_http_connection *conn, GError err, session->ctx->max_retries - session->retries); session->retries ++; - rspamd_upstream_fail (bk_conn->up); + rspamd_upstream_fail (bk_conn->up, FALSE); proxy_backend_close_connection (session->master_conn); if (session->ctx->max_retries && @@ -1810,7 +1810,7 @@ retry: host ? hostbuf : "default", rspamd_inet_address_to_string (rspamd_upstream_addr ( session->master_conn->up))); - rspamd_upstream_fail (session->master_conn->up); + rspamd_upstream_fail (session->master_conn->up, TRUE); session->retries ++; goto retry; } |