opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-22 04:09:04 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #5550 from ipfs/fix/coreapi-pin-lock

Browse Source 
take the pinlock when updating pins
This commit is contained in:
Steven Allen
2018-10-02 16:05:45 -07:00
committed by GitHub
parent 021fc9fb97 bf654ea4f8
commit d8ed9aba7d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/coreapi/pin.go
View File

@ -22,13 +22,13 @@ func (api *PinAPI) Add(ctx context.Context, p coreiface.Path, opts ...caopts.Pin
return err return err
} }
defer api.node.Blockstore.PinLock().Unlock()
rp, err := api.core().ResolvePath(ctx, p) rp, err := api.core().ResolvePath(ctx, p)
if err != nil { if err != nil {
return err return err
} }
defer api.node.Blockstore.PinLock().Unlock()
_, err = corerepo.Pin(api.node, api.core(), ctx, []string{rp.Cid().String()}, settings.Recursive) _, err = corerepo.Pin(api.node, api.core(), ctx, []string{rp.Cid().String()}, settings.Recursive)
if err != nil { if err != nil {
return err return err
@ -77,6 +77,8 @@ func (api *PinAPI) Update(ctx context.Context, from coreiface.Path, to coreiface
return err return err
} }
defer api.node.Blockstore.PinLock().Unlock()
err = api.node.Pinning.Update(ctx, fp.Cid(), tp.Cid(), settings.Unpin) err = api.node.Pinning.Update(ctx, fp.Cid(), tp.Cid(), settings.Unpin)
if err != nil { if err != nil {
return err return err