@@ -103,8 +103,8 @@ local function clamav_check(task, content, digest, rule) | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, '%s: retry IP: %s', | |||
rule.log_prefix, addr) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -146,15 +146,12 @@ local function dcc_check(task, content, digest, rule) | |||
retransmits = retransmits - 1 | |||
lua_util.debugm(rule.name, task, '%s: Request Error: %s - retries left: %s', | |||
rule.log_prefix, err, retransmits) | |||
-- Select a different upstream! | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, '%s: retry IP: %s:%s', | |||
rule.log_prefix, addr, addr:get_port()) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -103,7 +103,8 @@ local function fprot_check(task, content, digest, rule) | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, '%s [%s]: retry IP: %s', rule['symbol'], rule['type'], addr) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -122,8 +122,8 @@ local function kaspersky_check(task, content, digest, rule) | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, | |||
'%s [%s]: retry IP: %s', rule['symbol'], rule['type'], addr) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -106,16 +106,12 @@ local function oletools_check(task, content, digest, rule) | |||
retransmits = retransmits - 1 | |||
lua_util.debugm(rule.name, task, | |||
'%s: Request Error: %s - retries left: %s', | |||
rule.log_prefix, error, retransmits) | |||
-- Select a different upstream! | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, '%s: retry IP: %s:%s', | |||
rule.log_prefix, addr, addr:get_port()) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -210,9 +210,8 @@ local function savapi_check(task, content, digest, rule) | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, | |||
'%s [%s]: retry IP: %s', rule['symbol'], | |||
rule['type'], addr) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |
@@ -102,8 +102,8 @@ local function sophos_check(task, content, digest, rule) | |||
upstream = rule.upstreams:get_upstream_round_robin() | |||
addr = upstream:get_addr() | |||
lua_util.debugm(rule.name, task, | |||
'%s [%s]: retry IP: %s', rule['symbol'], rule['type'], addr) | |||
lua_util.debugm(rule.name, task, '%s: error: %s; retry IP: %s; retries left: %s', | |||
rule.log_prefix, err, addr, retransmits) | |||
tcp.request({ | |||
task = task, |