60ee6f739f
Refactor pkg/chrootarchive in terms of those utilities. Signed-off-by: Cory Snider <csnider@mirantis.com>
57 lines
1.3 KiB
Go
57 lines
1.3 KiB
Go
//go:build !windows
|
|
// +build !windows
|
|
|
|
package chrootarchive // import "github.com/docker/docker/pkg/chrootarchive"
|
|
|
|
import (
|
|
"io"
|
|
"path/filepath"
|
|
|
|
"github.com/containerd/containerd/pkg/userns"
|
|
"github.com/docker/docker/pkg/archive"
|
|
"golang.org/x/sys/unix"
|
|
)
|
|
|
|
// applyLayerHandler parses a diff in the standard layer format from `layer`, and
|
|
// applies it to the directory `dest`. Returns the size in bytes of the
|
|
// contents of the layer.
|
|
func applyLayerHandler(dest string, layer io.Reader, options *archive.TarOptions, decompress bool) (size int64, err error) {
|
|
dest = filepath.Clean(dest)
|
|
if decompress {
|
|
decompressed, err := archive.DecompressStream(layer)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
defer decompressed.Close()
|
|
|
|
layer = decompressed
|
|
}
|
|
if options == nil {
|
|
options = &archive.TarOptions{}
|
|
}
|
|
if userns.RunningInUserNS() {
|
|
options.InUserNS = true
|
|
}
|
|
if options.ExcludePatterns == nil {
|
|
options.ExcludePatterns = []string{}
|
|
}
|
|
|
|
type result struct {
|
|
layerSize int64
|
|
err error
|
|
}
|
|
|
|
done := make(chan result)
|
|
err = goInChroot(dest, func() {
|
|
// We need to be able to set any perms
|
|
_ = unix.Umask(0)
|
|
|
|
size, err := archive.UnpackLayer("/", layer, options)
|
|
done <- result{layerSize: size, err: err}
|
|
})
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
res := <-done
|
|
return res.layerSize, res.err
|
|
}
|