From: Vsevolod Stakhov <vsevolod@highsecure.ru>
Date: Thu, 10 May 2018 14:31:50 +0000 (+0100)
Subject: [Minor] Fix other AV engines retransmits
X-Git-Tag: 1.7.5~54
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=3248490bf53a4cb30d800d21192ed6f6ec91ba3a;p=thirdparty%2Frspamd.git

[Minor] Fix other AV engines retransmits
---

diff --git a/src/plugins/lua/antivirus.lua b/src/plugins/lua/antivirus.lua
index d5dc63ae0a..9464007439 100644
--- a/src/plugins/lua/antivirus.lua
+++ b/src/plugins/lua/antivirus.lua
@@ -382,6 +382,9 @@ local function fprot_check(task, rule)
         if err == 'IO timeout' then
           if retransmits > 0 then
             retransmits = retransmits - 1
+            -- Select a different upstream!
+            upstream = rule.upstreams:get_upstream_round_robin()
+            addr = upstream:get_addr()
             tcp.request({
               task = task,
               host = addr:to_string(),
@@ -548,6 +551,9 @@ local function sophos_check(task, rule)
         if err == 'IO timeout' then
           if retransmits > 0 then
             retransmits = retransmits - 1
+            -- Select a different upstream!
+            upstream = rule.upstreams:get_upstream_round_robin()
+            addr = upstream:get_addr()
             tcp.request({
               task = task,
               host = addr:to_string(),
@@ -713,6 +719,9 @@ local function savapi_check(task, rule)
         if err == 'IO timeout' then
           if retransmits > 0 then
             retransmits = retransmits - 1
+            -- Select a different upstream!
+            upstream = rule.upstreams:get_upstream_round_robin()
+            addr = upstream:get_addr()
             tcp.request({
               task = task,
               host = addr:to_string(),