Restoring authorship annotation for <msherbakov@yandex-team.ru>. Commit 1 of 2.

1 files changed, 132 insertions, 132 deletions

diff --git a/library/cpp/monlib/metrics/ewma.cpp b/library/cpp/monlib/metrics/ewma.cpp
index 8a296c3225..4838b40d6e 100644
--- a/library/cpp/monlib/metrics/ewma.cpp
+++ b/library/cpp/monlib/metrics/ewma.cpp
@@ -1,150 +1,150 @@
-#include "ewma.h"
+#include "ewma.h" 
 #include "metric.h"
-
-#include <atomic>
-#include <cmath>
-
-namespace NMonitoring {
-namespace {
-    constexpr auto DEFAULT_INTERVAL = TDuration::Seconds(5);
-
-    const double ALPHA1 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./1.);
-    const double ALPHA5 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./5.);
-    const double ALPHA15 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./15.);
-
-    class TExpMovingAverage final: public IExpMovingAverage {
-    public:
+ 
+#include <atomic> 
+#include <cmath> 
+ 
+namespace NMonitoring { 
+namespace { 
+    constexpr auto DEFAULT_INTERVAL = TDuration::Seconds(5); 
+ 
+    const double ALPHA1 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./1.); 
+    const double ALPHA5 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./5.); 
+    const double ALPHA15 = 1. - std::exp(-double(DEFAULT_INTERVAL.Seconds())/60./15.); 
+ 
+    class TExpMovingAverage final: public IExpMovingAverage { 
+    public: 
         explicit TExpMovingAverage(IGauge* metric, double alpha, TDuration interval)
             : Metric_{metric}
-            , Alpha_{alpha}
-            , Interval_{interval.Seconds()}
-        {
+            , Alpha_{alpha} 
+            , Interval_{interval.Seconds()} 
+        { 
             Y_VERIFY(metric != nullptr, "Passing nullptr metric is not allowed");
-        }
-
+        } 
+ 
         ~TExpMovingAverage() override = default;
-
-        // This method NOT thread safe
-        void Tick() override {
-            const auto current = Uncounted_.fetch_and(0);
-            const double instantRate = double(current) / Interval_;
-
-            if (Y_UNLIKELY(!IsInitialized())) {
+ 
+        // This method NOT thread safe 
+        void Tick() override { 
+            const auto current = Uncounted_.fetch_and(0); 
+            const double instantRate = double(current) / Interval_; 
+ 
+            if (Y_UNLIKELY(!IsInitialized())) { 
                 Metric_->Set(instantRate);
-                Init_ = true;
-            } else {
+                Init_ = true; 
+            } else { 
                 const double currentRate = Metric_->Get();
                 Metric_->Set(Alpha_ * (instantRate - currentRate) + currentRate);
-            }
-
-        }
-
-        void Update(i64 value) override {
-            Uncounted_ += value;
-        }
-
-        double Rate() const override {
+            } 
+ 
+        } 
+ 
+        void Update(i64 value) override { 
+            Uncounted_ += value; 
+        } 
+ 
+        double Rate() const override { 
             return Metric_->Get();
-        }
-
-        void Reset() override {
-            Init_ = false;
-            Uncounted_ = 0;
-        }
-
-    private:
-        bool IsInitialized() const {
-            return Init_;
-        }
-
-    private:
-        std::atomic<i64> Uncounted_{0};
-        std::atomic<bool> Init_{false};
-
+        } 
+ 
+        void Reset() override { 
+            Init_ = false; 
+            Uncounted_ = 0; 
+        } 
+ 
+    private: 
+        bool IsInitialized() const { 
+            return Init_; 
+        } 
+ 
+    private: 
+        std::atomic<i64> Uncounted_{0}; 
+        std::atomic<bool> Init_{false}; 
+ 
         IGauge* Metric_{nullptr};
-        double Alpha_;
-        ui64 Interval_;
-    };
-
-    struct TFakeEwma: IExpMovingAverage {
-        void Tick() override {}
-        void Update(i64) override {}
-        double Rate() const override { return 0; }
-        void Reset() override {}
-    };
-
-} // namespace
-
-    TEwmaMeter::TEwmaMeter()
-        : Ewma_{MakeHolder<TFakeEwma>()}
-    {
-    }
-
-    TEwmaMeter::TEwmaMeter(IExpMovingAveragePtr&& ewma)
-        : Ewma_{std::move(ewma)}
-    {
-    }
-
-    TEwmaMeter::TEwmaMeter(TEwmaMeter&& other) {
-        if (&other == this) {
-            return;
-        }
-
-        *this = std::move(other);
-    }
-
-    TEwmaMeter& TEwmaMeter::operator=(TEwmaMeter&& other) {
-        Ewma_ = std::move(other.Ewma_);
-        LastTick_.store(other.LastTick_);
-        return *this;
-    }
-
-    void TEwmaMeter::TickIfNeeded() {
-        constexpr ui64 INTERVAL_SECONDS = DEFAULT_INTERVAL.Seconds();
-
-        const auto now = TInstant::Now().Seconds();
-        ui64 old = LastTick_.load();
-        const auto secondsSinceLastTick = now - old;
-
-        if (secondsSinceLastTick > INTERVAL_SECONDS) {
-            // round to the interval grid
-            const ui64 newLast = now - (secondsSinceLastTick % INTERVAL_SECONDS);
-            if (LastTick_.compare_exchange_strong(old, newLast)) {
-                for (size_t i = 0; i < secondsSinceLastTick / INTERVAL_SECONDS; ++i) {
-                    Ewma_->Tick();
-                }
-            }
-        }
-    }
-
-    void TEwmaMeter::Mark() {
-        TickIfNeeded();
-        Ewma_->Update(1);
-    }
-
-    void TEwmaMeter::Mark(i64 value) {
-        TickIfNeeded();
-        Ewma_->Update(value);
-    }
-
-    double TEwmaMeter::Get() {
-        TickIfNeeded();
-        return Ewma_->Rate();
-    }
-
+        double Alpha_; 
+        ui64 Interval_; 
+    }; 
+ 
+    struct TFakeEwma: IExpMovingAverage { 
+        void Tick() override {} 
+        void Update(i64) override {} 
+        double Rate() const override { return 0; } 
+        void Reset() override {} 
+    }; 
+ 
+} // namespace 
+ 
+    TEwmaMeter::TEwmaMeter() 
+        : Ewma_{MakeHolder<TFakeEwma>()} 
+    { 
+    } 
+ 
+    TEwmaMeter::TEwmaMeter(IExpMovingAveragePtr&& ewma) 
+        : Ewma_{std::move(ewma)} 
+    { 
+    } 
+ 
+    TEwmaMeter::TEwmaMeter(TEwmaMeter&& other) { 
+        if (&other == this) { 
+            return; 
+        } 
+ 
+        *this = std::move(other); 
+    } 
+ 
+    TEwmaMeter& TEwmaMeter::operator=(TEwmaMeter&& other) { 
+        Ewma_ = std::move(other.Ewma_); 
+        LastTick_.store(other.LastTick_); 
+        return *this; 
+    } 
+ 
+    void TEwmaMeter::TickIfNeeded() { 
+        constexpr ui64 INTERVAL_SECONDS = DEFAULT_INTERVAL.Seconds(); 
+ 
+        const auto now = TInstant::Now().Seconds(); 
+        ui64 old = LastTick_.load(); 
+        const auto secondsSinceLastTick = now - old; 
+ 
+        if (secondsSinceLastTick > INTERVAL_SECONDS) { 
+            // round to the interval grid 
+            const ui64 newLast = now - (secondsSinceLastTick % INTERVAL_SECONDS); 
+            if (LastTick_.compare_exchange_strong(old, newLast)) { 
+                for (size_t i = 0; i < secondsSinceLastTick / INTERVAL_SECONDS; ++i) { 
+                    Ewma_->Tick(); 
+                } 
+            } 
+        } 
+    } 
+ 
+    void TEwmaMeter::Mark() { 
+        TickIfNeeded(); 
+        Ewma_->Update(1); 
+    } 
+ 
+    void TEwmaMeter::Mark(i64 value) { 
+        TickIfNeeded(); 
+        Ewma_->Update(value); 
+    } 
+ 
+    double TEwmaMeter::Get() { 
+        TickIfNeeded(); 
+        return Ewma_->Rate(); 
+    } 
+ 
     IExpMovingAveragePtr OneMinuteEwma(IGauge* metric) {
         return MakeHolder<TExpMovingAverage>(metric, ALPHA1, DEFAULT_INTERVAL);
-    }
-
+    } 
+ 
     IExpMovingAveragePtr FiveMinuteEwma(IGauge* metric) {
         return MakeHolder<TExpMovingAverage>(metric, ALPHA5, DEFAULT_INTERVAL);
-    }
-
+    } 
+ 
     IExpMovingAveragePtr FiveteenMinuteEwma(IGauge* metric) {
         return MakeHolder<TExpMovingAverage>(metric, ALPHA15, DEFAULT_INTERVAL);
-    }
-
+    } 
+ 
     IExpMovingAveragePtr CreateEwma(IGauge* metric, double alpha, TDuration interval) {
         return MakeHolder<TExpMovingAverage>(metric, alpha, interval);
-    }
-} // namespace NMonitoring
+    } 
+} // namespace NMonitoring