123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- //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 = Go(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
- }
|