fix pin-lock in dag put

License: MIT Signed-off-by: Steven Allen <steven@stebalien.com>
ipfs · Oct 27, 2018 · ce7d021 · ce7d021
1 parent b8d7d25
commit ce7d021
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/commands/dag/dag.go b/core/commands/dag/dag.go
@@ -89,6 +89,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 {
@@ -125,8 +129,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