(ctx context.Context, chainID, snapshotter string)
| 715 | } |
| 716 | |
| 717 | func (u *Unpacker) lockSnChainID(ctx context.Context, chainID, snapshotter string) (func(), error) { |
| 718 | key := u.makeChainIDKeyWithSnapshotter(chainID, snapshotter) |
| 719 | |
| 720 | if err := u.duplicationSuppressor.Lock(ctx, key); err != nil { |
| 721 | return nil, err |
| 722 | } |
| 723 | return func() { |
| 724 | u.duplicationSuppressor.Unlock(key) |
| 725 | }, nil |
| 726 | } |
| 727 | |
| 728 | func (u *Unpacker) lockBlobDescriptor(ctx context.Context, desc ocispec.Descriptor) (func(), error) { |
| 729 | key := u.makeBlobDescriptorKey(desc) |
no test coverage detected