Enable DuplicationSuppressor in transfer service

Signed-off-by: Henry Wang <henwang@amazon.com>
This commit is contained in:
Henry Wang
2025-05-29 22:28:43 +00:00
committed by k8s-infra-cherrypick-robot
parent 596748c174
commit d82921ff59

View File

@@ -30,6 +30,7 @@ import (
"github.com/containerd/containerd/v2/core/metadata"
"github.com/containerd/containerd/v2/core/transfer/local"
"github.com/containerd/containerd/v2/core/unpack"
"github.com/containerd/containerd/v2/internal/kmutex"
"github.com/containerd/containerd/v2/pkg/imageverifier"
"github.com/containerd/containerd/v2/plugins"
@@ -159,6 +160,7 @@ func init() {
lc.UnpackPlatforms = append(lc.UnpackPlatforms, up)
}
lc.RegistryConfigPath = config.RegistryConfigPath
lc.DuplicationSuppressor = kmutex.New()
return local.NewTransferService(ms.ContentStore(), metadata.NewImageStore(ms), lc), nil
},