Method tryLocalCanonicalClosure

engine/server/resolver/resolver.go:405–519

(
	ctx context.Context,
	resolvedRef string,
	rootDesc ocispecs.Descriptor,
	matcher platforms.MatchComparer,
	layerLimit *int,
)

}

func (r *Resolver) tryLocalCanonicalClosure(
	ctx context.Context,
	resolvedRef string,
	rootDesc ocispecs.Descriptor,
	matcher platforms.MatchComparer,
	layerLimit *int,
) (_ *localizedImageClosure, _ bool, _ func(context.Context) error, rerr error) {
	rootDesc, found, err := r.localCanonicalRootDescriptor(ctx, rootDesc.Digest)
	if err != nil || !found {
		return nil, found, nil, err
	}

	manifestDesc, manifest, found, err := tryResolveLocalManifestDescriptor(ctx, r.contentStore, rootDesc, matcher, true)
	if err != nil || !found {
		return nil, false, nil, err
	}

	configDesc := hydratePulledDescriptor(manifest.Config)
	if _, err := r.contentStore.Info(ctx, configDesc.Digest); err != nil {
		if cerrdefs.IsNotFound(err) {
			return nil, false, nil, nil
		}
		return nil, false, nil, err
	}

	diffIDs, err := images.RootFS(ctx, r.contentStore, configDesc)
	if err != nil {
		if cerrdefs.IsNotFound(err) {
			return nil, false, nil, nil
		}
		return nil, false, nil, err
	}
	if len(manifest.Layers) != len(diffIDs) {
		return nil, false, nil, fmt.Errorf("mismatched image rootfs and manifest layers: %d diffIDs vs %d layers", len(diffIDs), len(manifest.Layers))
	}

	layers := make([]ocispecs.Descriptor, len(manifest.Layers))
	for i, layer := range manifest.Layers {
		if _, err := r.contentStore.Info(ctx, layer.Digest); err != nil {
			if cerrdefs.IsNotFound(err) {
				return nil, false, nil, nil
			}
			return nil, false, nil, err
		}
		layer = hydratePulledDescriptor(layer)
		if layer.Annotations == nil {
			layer.Annotations = map[string]string{}
		}
		layer.Annotations["containerd.io/uncompressed"] = diffIDs[i].String()
		layers[i] = layer
	}
	if layerLimit != nil {
		if *layerLimit > len(layers) {
			return nil, false, nil, fmt.Errorf("layer limit %d exceeds image layer count %d", *layerLimit, len(layers))
		}
		layers = layers[:*layerLimit]
	}