Check if a block already exists before write it

planetarium#662 (comment)
dahlia · Nov 13, 2019 · c8c6bdd · c8c6bdd
1 parent feb6fca
commit c8c6bdd
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/Libplanet/Store/DefaultStore.cs b/Libplanet/Store/DefaultStore.cs
@@ -406,16 +406,18 @@ public override void PutBlock<T>(Block<T> block)
                 return;
             }
 
+            UPath path = BlockPath(block.Hash);
+            if (_blocks.FileExists(path))
+            {
+                return;
+            }
+
             foreach (Transaction<T> tx in block.Transactions)
             {
                 PutTransaction(tx);
             }
 
-            WriteContentAddressableFile(
-                _blocks,
-                BlockPath(block.Hash),
-                block.ToBencodex(true, false)
-            );
+            WriteContentAddressableFile(_blocks, path, block.ToBencodex(true, false));
             _blockCache.AddOrUpdate(block.Hash, block.ToRawBlock(false, false));
         }