From d82921ff59cc91c1d75d35cc1cb3a5e709da9fdd Mon Sep 17 00:00:00 2001 From: Henry Wang Date: Thu, 29 May 2025 22:28:43 +0000 Subject: [PATCH] Enable DuplicationSuppressor in transfer service Signed-off-by: Henry Wang --- plugins/transfer/plugin.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/plugins/transfer/plugin.go b/plugins/transfer/plugin.go index b97d1a4872..4c61b898b4 100644 --- a/plugins/transfer/plugin.go +++ b/plugins/transfer/plugin.go @@ -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 },