aboutsummaryrefslogtreecommitdiffstats
path: root/config
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-12-20 15:26:59 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-12-20 15:26:59 +0000
commit9f662df868bbc8bbdb535c306cf498360eb0c3d5 (patch)
treea8b1838cbbb761b0d954f01ce645177d0337dedb /config
parentc7748cd34d9316e444a6005d2eba863ffbeac3cb (diff)
Only log warning every 10s and give a understandable name to a constant
Diffstat (limited to 'config')
-rw-r--r--config/src/vespa/config/frt/frtconnection.cpp13
1 files changed, 10 insertions, 3 deletions
diff --git a/config/src/vespa/config/frt/frtconnection.cpp b/config/src/vespa/config/frt/frtconnection.cpp
index 0c5d21ae4e9..466239200d4 100644
--- a/config/src/vespa/config/frt/frtconnection.cpp
+++ b/config/src/vespa/config/frt/frtconnection.cpp
@@ -87,6 +87,13 @@ void FRTConnection::setSuccess()
_suspendedUntil = steady_time();
}
+namespace {
+
+constexpr uint32_t MAX_DELAY_MULTIPLIER = 6u;
+constexpr vespalib::duration WARN_INTERVAL = 10s;
+
+}
+
void FRTConnection::calculateSuspension(ErrorType type)
{
duration delay = duration::zero();
@@ -94,15 +101,15 @@ void FRTConnection::calculateSuspension(ErrorType type)
std::lock_guard guard(_lock);
switch(type) {
case TRANSIENT:
- delay = std::min(6u, ++_transientFailures) * _transientDelay;
+ delay = std::min(MAX_DELAY_MULTIPLIER, ++_transientFailures) * _transientDelay;
LOG(warning, "Connection to %s failed or timed out", _address.c_str());
break;
case FATAL:
- delay = std::min(6u, ++_fatalFailures) * _fatalDelay;
+ delay = std::min(MAX_DELAY_MULTIPLIER, ++_fatalFailures) * _fatalDelay;
break;
}
_suspendedUntil = now + delay;
- if (_suspendWarned < (now - 5s)) {
+ if (_suspendWarned < (now - WARN_INTERVAL)) {
LOG(warning, "FRT Connection %s suspended until %s", _address.c_str(), vespalib::to_string(to_utc(_suspendedUntil)).c_str());
_suspendWarned = now;
}