Final part on compatibility layer: LOGBROKER-7215

ref:777c67aadbf705d19034a09a792b2df61ba53697

1 files changed, 44 insertions, 0 deletions

diff --git a/library/cpp/tvmauth/client/ut/exponential_backoff_ut.cpp b/library/cpp/tvmauth/client/ut/exponential_backoff_ut.cpp
new file mode 100644
index 0000000000..3dcbe6ad49
--- /dev/null
+++ b/library/cpp/tvmauth/client/ut/exponential_backoff_ut.cpp
@@ -0,0 +1,44 @@
+#include <library/cpp/tvmauth/client/misc/exponential_backoff.h>
+
+#include <library/cpp/testing/unittest/registar.h>
+
+#include <thread>
+
+using namespace NTvmAuth;
+
+Y_UNIT_TEST_SUITE(PasspUtilsExpBackoff) {
+    Y_UNIT_TEST(common) {
+        TExponentialBackoff b({TDuration::Seconds(1), TDuration::Seconds(60), 2, 0.01});
+
+        UNIT_ASSERT_VALUES_EQUAL(TDuration::Seconds(1), b.GetCurrentValue());
+
+        TDuration dur = b.GetCurrentValue();
+        for (size_t idx = 0; idx < 6; ++idx) {
+            TDuration newValue = b.Increase();
+            UNIT_ASSERT_LT(dur, newValue);
+            dur = newValue;
+        }
+
+        UNIT_ASSERT_LT(TDuration::Seconds(60) - TDuration::Seconds(3), dur);
+        UNIT_ASSERT_LT(dur, TDuration::Seconds(60) + TDuration::Seconds(3));
+    }
+
+    Y_UNIT_TEST(sleep) {
+        TExponentialBackoff b({TDuration::Seconds(60), TDuration::Seconds(600), 2, 0.01});
+
+        const TInstant start = TInstant::Now();
+
+        TAutoEvent started;
+        std::thread t([&b, &started]() {
+            started.Signal();
+            b.Sleep();
+        });
+
+        started.WaitT(TDuration::Seconds(30));
+        b.Interrupt();
+        t.join();
+        TDuration dur = TInstant::Now() - start;
+
+        UNIT_ASSERT_LT(dur, TDuration::Seconds(60));
+    }
+}