Repeat recurse/direct pin checks since they could have changed

License: MIT Signed-off-by: Michael Avila <[email protected]>
ipfs · Sep 27, 2018 · 7ed1a53 · 7ed1a53
1 parent 254ac1b
commit 7ed1a53
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pin/pin.go b/pin/pin.go
@@ -236,6 +236,14 @@ func (p *pinner) Pin(ctx context.Context, node ipld.Node, recurse bool) error {
 			return err
 		}
 
+		if p.recursePin.Has(c) {
+			return nil
+		}
+
+		if p.directPin.Has(c) {
+			p.directPin.Remove(c)
+		}
+
 		p.recursePin.Add(c)
 	} else {
 		p.lock.Unlock()