diff options
| -rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/tls_replay_progress.h | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/tls_replay_progress.h b/searchcore/src/vespa/searchcore/proton/server/tls_replay_progress.h index ce0195ad120..5bd1b6382f4 100644 --- a/searchcore/src/vespa/searchcore/proton/server/tls_replay_progress.h +++ b/searchcore/src/vespa/searchcore/proton/server/tls_replay_progress.h @@ -4,6 +4,7 @@ #include <vespa/searchlib/common/serialnum.h> #include <vespa/vespalib/stllike/string.h> +#include <atomic> namespace proton { @@ -13,7 +14,7 @@ private: const vespalib::string _domainName; const search::SerialNum _first; const search::SerialNum _last; - search::SerialNum _current; + std::atomic<search::SerialNum> _current; public: typedef std::unique_ptr<TlsReplayProgress> UP; @@ -27,18 +28,18 @@ public: _current(first) { } - const vespalib::string &getDomainName() const { return _domainName; } - search::SerialNum getFirst() const { return _first; } - search::SerialNum getLast() const { return _last; } - search::SerialNum getCurrent() const { return _current; } - float getProgress() const { + const vespalib::string &getDomainName() const noexcept { return _domainName; } + search::SerialNum getFirst() const noexcept { return _first; } + search::SerialNum getLast() const noexcept { return _last; } + search::SerialNum getCurrent() const noexcept { return _current.load(std::memory_order_relaxed); } + float getProgress() const noexcept { if (_first == _last) { return 1.0; } else { - return ((float)(_current - _first)/float(_last - _first)); + return ((float)(getCurrent() - _first)/float(_last - _first)); } } - void updateCurrent(search::SerialNum current) { _current = current; } + void updateCurrent(search::SerialNum current) noexcept { _current.store(current, std::memory_order_relaxed); } }; } // namespace proton |