lint

amplitude · Nov 1, 2024 · 01ac942 · 01ac942
1 parent 9b46edc
commit 01ac942
Showing 1 changed file with 27 additions and 19 deletions.
diff --git a/src/main/kotlin/flag/FlagConfigUpdater.kt b/src/main/kotlin/flag/FlagConfigUpdater.kt
@@ -303,26 +303,30 @@ internal class FlagConfigFallbackRetryWrapper(
 
     private fun scheduleRetry() {
         lock.withLock {
-            retryTask = executor.schedule({
-                lock.withLock {
-                    if (!isRunning) {
-                        return@schedule
-                    }
-                    try {
-                        mainUpdater.start {
-                            lock.withLock {
-                                if (isRunning) {
-                                    scheduleRetry() // Don't care if poller start error or not, always retry.
-                                    fallbackStart()
+            retryTask = executor.schedule(
+                {
+                    lock.withLock {
+                        if (!isRunning) {
+                            return@schedule
+                        }
+                        try {
+                            mainUpdater.start {
+                                lock.withLock {
+                                    if (isRunning) {
+                                        scheduleRetry() // Don't care if poller start error or not, always retry.
+                                        fallbackStart()
+                                    }
                                 }
                             }
+                            fallbackStop()
+                        } catch (_: Throwable) {
+                            scheduleRetry()
                         }
-                        fallbackStop()
-                    } catch (_: Throwable) {
-                        scheduleRetry()
                     }
-                }
-            }, reconnIntervalRange.random(), TimeUnit.MILLISECONDS)
+                },
+                reconnIntervalRange.random(),
+                TimeUnit.MILLISECONDS
+            )
         }
     }
 
@@ -332,9 +336,13 @@ internal class FlagConfigFallbackRetryWrapper(
                 fallbackUpdater?.start()
             } catch (_: Throwable) {
                 if (isRunning) {
-                    fallbackRetryTask = executor.schedule({
-                        fallbackStart()
-                    }, fallbackReconnIntervalRange.random(), TimeUnit.MILLISECONDS)
+                    fallbackRetryTask = executor.schedule(
+                        {
+                            fallbackStart()
+                        },
+                        fallbackReconnIntervalRange.random(),
+                        TimeUnit.MILLISECONDS
+                    )
                 } else {}
             }
         }