diff options
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/vespa/messagebus/routing/retrytransienterrorspolicy.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/vespa/messagebus/routing/retrytransienterrorspolicy.cpp b/messagebus/src/vespa/messagebus/routing/retrytransienterrorspolicy.cpp index fa43a964f90..7a2147b13ff 100644 --- a/messagebus/src/vespa/messagebus/routing/retrytransienterrorspolicy.cpp +++ b/messagebus/src/vespa/messagebus/routing/retrytransienterrorspolicy.cpp @@ -24,12 +24,12 @@ RetryTransientErrorsPolicy::setBaseDelay(double baseDelay) { bool RetryTransientErrorsPolicy::canRetry(uint32_t errorCode) const { - return _enabled && errorCode < ErrorCode::FATAL_ERROR; + return _enabled.load(std::memory_order_relaxed) && errorCode < ErrorCode::FATAL_ERROR; } double RetryTransientErrorsPolicy::getRetryDelay(uint32_t retry) const { - return _baseDelay * retry; + return _baseDelay.load(std::memory_order_relaxed) * retry; } } |