mirror of
https://github.com/moby/moby.git
synced 2026-01-11 18:51:37 +00:00
76 lines
2.3 KiB
Go
76 lines
2.3 KiB
Go
package containerd
|
|
|
|
import (
|
|
"context"
|
|
|
|
c8dimages "github.com/containerd/containerd/v2/core/images"
|
|
cerrdefs "github.com/containerd/errdefs"
|
|
"github.com/moby/moby/v2/errdefs"
|
|
"github.com/opencontainers/go-digest"
|
|
ocispec "github.com/opencontainers/image-spec/specs-go/v1"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
const imageNameDanglingPrefix = "moby-dangling@"
|
|
|
|
// softImageDelete deletes the image, making sure that there are other images
|
|
// that reference the content of the deleted image.
|
|
// If no other image exists, a dangling one is created.
|
|
func (i *ImageService) softImageDelete(ctx context.Context, img c8dimages.Image, imgs []c8dimages.Image) error {
|
|
// From this point explicitly ignore the passed context
|
|
// and don't allow to interrupt operation in the middle.
|
|
|
|
// Create dangling image if this is the last image pointing to this target.
|
|
if len(imgs) == 1 {
|
|
err := i.ensureDanglingImage(context.WithoutCancel(ctx), img)
|
|
// Error out in case we couldn't persist the old image.
|
|
if err != nil {
|
|
return errdefs.System(errors.Wrapf(err, "failed to create a dangling image for the replaced image %s with digest %s",
|
|
img.Name, img.Target.Digest.String()))
|
|
}
|
|
}
|
|
|
|
// Free the target name.
|
|
// TODO: Add with target option
|
|
err := i.images.Delete(context.WithoutCancel(ctx), img.Name)
|
|
if err != nil {
|
|
if !cerrdefs.IsNotFound(err) {
|
|
return errdefs.System(errors.Wrapf(err, "failed to delete image %s which existed a moment before", img.Name))
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (i *ImageService) ensureDanglingImage(ctx context.Context, from c8dimages.Image) error {
|
|
danglingImage := from
|
|
|
|
danglingImage.Labels = make(map[string]string)
|
|
for k, v := range from.Labels {
|
|
switch k {
|
|
case c8dimages.AnnotationImageName, ocispec.AnnotationRefName:
|
|
// Don't copy name labels.
|
|
default:
|
|
danglingImage.Labels[k] = v
|
|
}
|
|
}
|
|
danglingImage.Name = danglingImageName(from.Target.Digest)
|
|
|
|
_, err := i.images.Create(context.WithoutCancel(ctx), danglingImage)
|
|
// If it already exists, then just continue.
|
|
if cerrdefs.IsAlreadyExists(err) {
|
|
return nil
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
func danglingImageName(digest digest.Digest) string {
|
|
return imageNameDanglingPrefix + digest.String()
|
|
}
|
|
|
|
func isDanglingImage(image c8dimages.Image) bool {
|
|
// TODO: Also check for expired
|
|
return image.Name == danglingImageName(image.Target.Digest)
|
|
}
|