archive: use zstd if available

the performance improvement is not as clear as with pigz, but it is still measurable difference. Signed-off-by: Giuseppe Scrivano <[email protected]>
containers · Jun 11, 2024 · ae8836f · ae8836f
1 parent b3319f0
commit ae8836f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/archive/archive.go b/pkg/archive/archive.go
@@ -220,6 +220,12 @@ func DecompressStream(archive io.Reader) (_ io.ReadCloser, Err error) {
 		readBufWrapper := p.NewReadCloserWrapper(buf, xzReader)
 		return readBufWrapper, nil
 	case Zstd:
+		cleanup := func() {
+			p.Put(buf)
+		}
+		if rc, canUse := tryProcFilter([]string{"zstd", "-d"}, buf, cleanup); canUse {
+			return rc, nil
+		}
 		return zstdReader(buf)
 	default:
 		return nil, fmt.Errorf("unsupported compression format %s", (&compression).Extension())