aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/metrics/atomics_array.h
diff options
context:
space:
mode:
authorSergey Polovko <sergey@polovko.me>2022-02-10 16:47:02 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:02 +0300
commit3e0b762a82514bac89c1dd6ea7211e381d8aa248 (patch)
treec2d1b379ecaf05ca8f11ed0b5da9d1a950e6e554 /library/cpp/monlib/metrics/atomics_array.h
parentab3783171cc30e262243a0227c86118f7080c896 (diff)
downloadydb-3e0b762a82514bac89c1dd6ea7211e381d8aa248.tar.gz
Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/metrics/atomics_array.h')
-rw-r--r--library/cpp/monlib/metrics/atomics_array.h76
1 files changed, 38 insertions, 38 deletions
diff --git a/library/cpp/monlib/metrics/atomics_array.h b/library/cpp/monlib/metrics/atomics_array.h
index f19aebf291..c9193f0a33 100644
--- a/library/cpp/monlib/metrics/atomics_array.h
+++ b/library/cpp/monlib/metrics/atomics_array.h
@@ -1,52 +1,52 @@
-#pragma once
-
-#include <util/generic/ptr.h>
-#include <util/generic/vector.h>
-
+#pragma once
+
+#include <util/generic/ptr.h>
+#include <util/generic/vector.h>
+
#include <atomic>
-namespace NMonitoring {
- class TAtomicsArray {
- public:
- explicit TAtomicsArray(size_t size)
+namespace NMonitoring {
+ class TAtomicsArray {
+ public:
+ explicit TAtomicsArray(size_t size)
: Values_(new std::atomic<ui64>[size])
- , Size_(size)
- {
- for (size_t i = 0; i < Size_; i++) {
+ , Size_(size)
+ {
+ for (size_t i = 0; i < Size_; i++) {
Values_[i].store(0, std::memory_order_relaxed);
- }
- }
-
- ui64 operator[](size_t index) const noexcept {
- Y_VERIFY_DEBUG(index < Size_);
+ }
+ }
+
+ ui64 operator[](size_t index) const noexcept {
+ Y_VERIFY_DEBUG(index < Size_);
return Values_[index].load(std::memory_order_relaxed);
- }
-
- size_t Size() const noexcept {
- return Size_;
- }
-
- void Add(size_t index, ui32 count) noexcept {
- Y_VERIFY_DEBUG(index < Size_);
+ }
+
+ size_t Size() const noexcept {
+ return Size_;
+ }
+
+ void Add(size_t index, ui32 count) noexcept {
+ Y_VERIFY_DEBUG(index < Size_);
Values_[index].fetch_add(count, std::memory_order_relaxed);
- }
-
+ }
+
void Reset() noexcept {
for (size_t i = 0; i < Size_; i++) {
Values_[i].store(0, std::memory_order_relaxed);
}
}
- TVector<ui64> Copy() const {
- TVector<ui64> copy(Reserve(Size_));
- for (size_t i = 0; i < Size_; i++) {
+ TVector<ui64> Copy() const {
+ TVector<ui64> copy(Reserve(Size_));
+ for (size_t i = 0; i < Size_; i++) {
copy.push_back(Values_[i].load(std::memory_order_relaxed));
- }
- return copy;
- }
-
- private:
+ }
+ return copy;
+ }
+
+ private:
TArrayHolder<std::atomic<ui64>> Values_;
- size_t Size_;
- };
-}
+ size_t Size_;
+ };
+}