fix pin-lock in dag put

License: MIT Signed-off-by: Steven Allen <[email protected]>
ipfs · Oct 26, 2018 · 7ed86f8 · 7ed86f8
1 parent 617c54c
commit 7ed86f8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/commands/dag/dag.go b/core/commands/dag/dag.go
@@ -88,6 +88,10 @@ into an object of the specified format.
 		cids := cid.NewSet()
 		b := ipld.NewBatch(req.Context, nd.DAG)
 
+		if dopin {
+			defer nd.Blockstore.PinLock().Unlock()
+		}
+
 		for {
 			file, err := req.Files.NextFile()
 			if err == io.EOF {
@@ -124,8 +128,6 @@ into an object of the specified format.
 		}
 
 		if dopin {
-			defer nd.Blockstore.PinLock().Unlock()
-
 			cids.ForEach(func(c cid.Cid) error {
 				nd.Pinning.PinWithMode(c, pin.Recursive)
 				return nil