intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 26 insertions, 0 deletions

diff --git a/library/cpp/retry/retry.cpp b/library/cpp/retry/retry.cpp
new file mode 100644
index 00000000000..92466cdeca5
--- /dev/null
+++ b/library/cpp/retry/retry.cpp
@@ -0,0 +1,26 @@
+#include "retry.h"
+
+#include <util/stream/output.h>
+
+void DoWithRetry(std::function<void()> func, TRetryOptions retryOptions) {
+    DoWithRetry(func, retryOptions, true);
+}
+
+bool DoWithRetryOnRetCode(std::function<bool()> func, TRetryOptions retryOptions) {
+    for (ui32 attempt = 0; attempt <= retryOptions.RetryCount; ++attempt) {
+        if (func()) {
+            return true;
+        }
+        auto sleep = retryOptions.SleepFunction;
+        sleep(retryOptions.GetTimeToSleep(attempt));
+    }
+    return false;
+}
+
+TRetryOptions MakeRetryOptions(const NRetry::TRetryOptionsPB& retryOptions) {
+    return TRetryOptions(retryOptions.GetMaxTries(),
+                         TDuration::MilliSeconds(retryOptions.GetInitialSleepMs()),
+                         TDuration::MilliSeconds(retryOptions.GetRandomDeltaMs()),
+                         TDuration::MilliSeconds(retryOptions.GetSleepIncrementMs()),
+                         TDuration::MilliSeconds(retryOptions.GetExponentalMultiplierMs()));
+}