Ydb stable 23-1-1923.1.19

x-stable-origin-commit: c5d5a396e89d0a72e0267a55e93d8404d4fb54fe

1 files changed, 43 insertions, 0 deletions

diff --git a/library/cpp/unified_agent_client/duration_counter.h b/library/cpp/unified_agent_client/duration_counter.h
new file mode 100644
index 0000000000..dbdfc22ed4
--- /dev/null
+++ b/library/cpp/unified_agent_client/duration_counter.h
@@ -0,0 +1,43 @@
+#pragma once
+
+#include <library/cpp/monlib/dynamic_counters/counters.h>
+
+#include <util/generic/deque.h>
+#include <util/system/hp_timer.h>
+#include <util/system/mutex.h>
+
+namespace NUnifiedAgent {
+    class TDurationUsCounter {
+    public:
+        class TScope {
+        public:
+            TScope(TDurationUsCounter& counter)
+                : Counter(counter)
+                , StartTime(Counter.Begin())
+            {
+            }
+
+            ~TScope() {
+                Counter.End(StartTime);
+            }
+
+        private:
+            TDurationUsCounter& Counter;
+            NHPTimer::STime* StartTime;
+        };
+
+    public:
+        TDurationUsCounter(const TString& name, NMonitoring::TDynamicCounters& owner);
+
+        NHPTimer::STime* Begin();
+
+        void End(NHPTimer::STime* startTime);
+
+        void Update();
+
+    private:
+        NMonitoring::TDeprecatedCounter& Counter;
+        TDeque<NHPTimer::STime> ActiveTimers;
+        TAdaptiveLock Lock;
+    };
+}