Removed retrying logic when block downloading

planetarium · Oct 30, 2020 · 5913e5a · 5913e5a
1 parent 1c9d402
commit 5913e5a
Showing 1 changed file with 18 additions and 44 deletions.
diff --git a/Libplanet/Net/Swarm.cs b/Libplanet/Net/Swarm.cs
@@ -1683,56 +1683,30 @@ private async Task SyncPreviousBlocksAsync(
             CancellationToken cancellationToken
         )
         {
-            int retry = 3;
             long previousTipIndex = blockChain.Tip?.Index ?? -1;
             BlockChain<T> synced = null;
 
             try
             {
-                while (true)
-                {
-                    cancellationToken.ThrowIfCancellationRequested();
+                long currentTipIndex = blockChain.Tip?.Index ?? -1;
+                long receivedBlockCount = currentTipIndex - previousTipIndex;
 
-                    try
-                    {
-                        long currentTipIndex = blockChain.Tip?.Index ?? -1;
-                        long receivedBlockCount = currentTipIndex - previousTipIndex;
-
-                        FillBlocksAsyncStarted.Set();
-                        synced = await FillBlocksAsync(
-                            peer,
-                            blockChain,
-                            stop,
-                            progress,
-                            totalBlockCount,
-                            receivedBlockCount,
-                            true,
-                            cancellationToken
-                        );
-                        break;
-                    }
-                    catch (TimeoutException e)
-                    {
-                        if (retry > 0)
-                        {
-                            _logger.Error(
-                                e,
-                                $"{nameof(FillBlocksAsync)}() failed; retrying...: {e}"
-                            );
-                            retry--;
-                        }
-                        else
-                        {
-                            FillBlocksAsyncFailed.Set();
-                            throw;
-                        }
-                    }
-                    catch (Exception)
-                    {
-                        FillBlocksAsyncFailed.Set();
-                        throw;
-                    }
-                }
+                FillBlocksAsyncStarted.Set();
+                synced = await FillBlocksAsync(
+                    peer,
+                    blockChain,
+                    stop,
+                    progress,
+                    totalBlockCount,
+                    receivedBlockCount,
+                    true,
+                    cancellationToken
+                );
+            }
+            catch (Exception)
+            {
+                FillBlocksAsyncFailed.Set();
+                throw;
             }
             finally
             {