vendor: update tonistiigi/fsutil v0.0.0-20200720184806-8f851f9d2045
full diff: ae3a8d7530...8f851f9d20
notable changes:
- walker: fix notadir error
- improving error returns
- more typed errors
- remove extra verbosity (eg. PathError already contains action and path)
- ensure stack traces are added to errors
Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
v0.8
parent
b3cf4e508c
commit
3890bbe6f7
2
go.mod
2
go.mod
|
@ -55,7 +55,7 @@ require (
|
||||||
github.com/sirupsen/logrus v1.4.2
|
github.com/sirupsen/logrus v1.4.2
|
||||||
github.com/stretchr/testify v1.5.1
|
github.com/stretchr/testify v1.5.1
|
||||||
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2 // indirect
|
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2 // indirect
|
||||||
github.com/tonistiigi/fsutil v0.0.0-20200512175118-ae3a8d753069
|
github.com/tonistiigi/fsutil v0.0.0-20200720184806-8f851f9d2045
|
||||||
github.com/tonistiigi/units v0.0.0-20180711220420-6950e57a87ea
|
github.com/tonistiigi/units v0.0.0-20180711220420-6950e57a87ea
|
||||||
github.com/uber/jaeger-client-go v2.11.2+incompatible
|
github.com/uber/jaeger-client-go v2.11.2+incompatible
|
||||||
github.com/uber/jaeger-lib v1.2.1 // indirect
|
github.com/uber/jaeger-lib v1.2.1 // indirect
|
||||||
|
|
4
go.sum
4
go.sum
|
@ -213,8 +213,8 @@ github.com/stretchr/testify v1.5.1 h1:nOGnQDM7FYENwehXlg/kFVnos3rEvtKTjRvOWSzb6H
|
||||||
github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
|
github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
|
||||||
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2 h1:b6uOv7YOFK0TYG7HtkIgExQo+2RdLuwRft63jn2HWj8=
|
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2 h1:b6uOv7YOFK0TYG7HtkIgExQo+2RdLuwRft63jn2HWj8=
|
||||||
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2/go.mod h1:hkRG7XYTFWNJGYcbNJQlaLq0fg1yr4J4t/NcTQtrfww=
|
github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2/go.mod h1:hkRG7XYTFWNJGYcbNJQlaLq0fg1yr4J4t/NcTQtrfww=
|
||||||
github.com/tonistiigi/fsutil v0.0.0-20200512175118-ae3a8d753069 h1:F8MYILe5YNjbPLpmF/OgYrfsHBnAFZecylt1AXl8zow=
|
github.com/tonistiigi/fsutil v0.0.0-20200720184806-8f851f9d2045 h1:aARPR+qSaJk8cf3pi09cdUxWF1UJ/3xFaZRwRewzdic=
|
||||||
github.com/tonistiigi/fsutil v0.0.0-20200512175118-ae3a8d753069/go.mod h1:uA7OEv9Ab41e89xMMPlecftcyNsXGVHuI71vi1acNeg=
|
github.com/tonistiigi/fsutil v0.0.0-20200720184806-8f851f9d2045/go.mod h1:uA7OEv9Ab41e89xMMPlecftcyNsXGVHuI71vi1acNeg=
|
||||||
github.com/tonistiigi/go-immutable-radix v0.0.0-20170803185627-826af9ccf0fe h1:pd7hrFSqUPxYS9IB+UMG1AB/8EXGXo17ssx0bSQ5L6Y=
|
github.com/tonistiigi/go-immutable-radix v0.0.0-20170803185627-826af9ccf0fe h1:pd7hrFSqUPxYS9IB+UMG1AB/8EXGXo17ssx0bSQ5L6Y=
|
||||||
github.com/tonistiigi/go-immutable-radix v0.0.0-20170803185627-826af9ccf0fe/go.mod h1:/+MCh11CJf2oz0BXmlmqyopK/ad1rKkcOXPoYuPCJYU=
|
github.com/tonistiigi/go-immutable-radix v0.0.0-20170803185627-826af9ccf0fe/go.mod h1:/+MCh11CJf2oz0BXmlmqyopK/ad1rKkcOXPoYuPCJYU=
|
||||||
github.com/tonistiigi/units v0.0.0-20180711220420-6950e57a87ea h1:SXhTLE6pb6eld/v/cCndK0AMpt1wiVFb/YYmqB3/QG0=
|
github.com/tonistiigi/units v0.0.0-20180711220420-6950e57a87ea h1:SXhTLE6pb6eld/v/cCndK0AMpt1wiVFb/YYmqB3/QG0=
|
||||||
|
|
|
@ -0,0 +1,9 @@
|
||||||
|
# if you want to ignore files created by your editor/tools, consider using a
|
||||||
|
# global .gitignore or .git/info/exclude see https://help.github.com/articles/ignoring-files
|
||||||
|
.*
|
||||||
|
!.github
|
||||||
|
!.gitignore
|
||||||
|
!.travis.yml
|
||||||
|
*.prof
|
||||||
|
# support running go modules in vendor mode for local development
|
||||||
|
vendor/
|
|
@ -5,16 +5,18 @@ package fsutil
|
||||||
import (
|
import (
|
||||||
"os"
|
"os"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/pkg/errors"
|
||||||
)
|
)
|
||||||
|
|
||||||
func chtimes(path string, un int64) error {
|
func chtimes(path string, un int64) error {
|
||||||
mtime := time.Unix(0, un)
|
mtime := time.Unix(0, un)
|
||||||
fi, err := os.Lstat(path)
|
fi, err := os.Lstat(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
if fi.Mode()&os.ModeSymlink != 0 {
|
if fi.Mode()&os.ModeSymlink != 0 {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
return os.Chtimes(path, mtime, mtime)
|
return errors.WithStack(os.Chtimes(path, mtime, mtime))
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,7 +21,7 @@ type ContentHasher func(*types.Stat) (hash.Hash, error)
|
||||||
|
|
||||||
func GetWalkerFn(root string) walkerFn {
|
func GetWalkerFn(root string) walkerFn {
|
||||||
return func(ctx context.Context, pathC chan<- *currentPath) error {
|
return func(ctx context.Context, pathC chan<- *currentPath) error {
|
||||||
return Walk(ctx, root, nil, func(path string, f os.FileInfo, err error) error {
|
return errors.Wrap(Walk(ctx, root, nil, func(path string, f os.FileInfo, err error) error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -42,7 +42,7 @@ func GetWalkerFn(root string) walkerFn {
|
||||||
case pathC <- p:
|
case pathC <- p:
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
})
|
}), "failed to walk")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -8,6 +8,7 @@ import (
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strconv"
|
"strconv"
|
||||||
"sync"
|
"sync"
|
||||||
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/opencontainers/go-digest"
|
"github.com/opencontainers/go-digest"
|
||||||
|
@ -104,7 +105,7 @@ func (dw *DiskWriter) HandleChange(kind ChangeKind, p string, fi os.FileInfo, er
|
||||||
|
|
||||||
stat, ok := fi.Sys().(*types.Stat)
|
stat, ok := fi.Sys().(*types.Stat)
|
||||||
if !ok {
|
if !ok {
|
||||||
return errors.Errorf("%s invalid change without stat information", p)
|
return errors.WithStack(&os.PathError{Path: p, Err: syscall.EBADMSG, Op: "change without stat info"})
|
||||||
}
|
}
|
||||||
|
|
||||||
statCopy := *stat
|
statCopy := *stat
|
||||||
|
@ -118,13 +119,13 @@ func (dw *DiskWriter) HandleChange(kind ChangeKind, p string, fi os.FileInfo, er
|
||||||
rename := true
|
rename := true
|
||||||
oldFi, err := os.Lstat(destPath)
|
oldFi, err := os.Lstat(destPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if os.IsNotExist(err) {
|
if errors.Is(err, os.ErrNotExist) {
|
||||||
if kind != ChangeKindAdd {
|
if kind != ChangeKindAdd {
|
||||||
return errors.Wrapf(err, "invalid addition: %s", destPath)
|
return errors.Wrap(err, "modify/rm")
|
||||||
}
|
}
|
||||||
rename = false
|
rename = false
|
||||||
} else {
|
} else {
|
||||||
return errors.Wrapf(err, "failed to stat %s", destPath)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -17,17 +17,17 @@ func rewriteMetadata(p string, stat *types.Stat) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := os.Lchown(p, int(stat.Uid), int(stat.Gid)); err != nil {
|
if err := os.Lchown(p, int(stat.Uid), int(stat.Gid)); err != nil {
|
||||||
return errors.Wrapf(err, "failed to lchown %s", p)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if os.FileMode(stat.Mode)&os.ModeSymlink == 0 {
|
if os.FileMode(stat.Mode)&os.ModeSymlink == 0 {
|
||||||
if err := os.Chmod(p, os.FileMode(stat.Mode)); err != nil {
|
if err := os.Chmod(p, os.FileMode(stat.Mode)); err != nil {
|
||||||
return errors.Wrapf(err, "failed to chown %s", p)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := chtimes(p, stat.ModTime); err != nil {
|
if err := chtimes(p, stat.ModTime); err != nil {
|
||||||
return errors.Wrapf(err, "failed to chtimes %s", p)
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
@ -46,7 +46,7 @@ func handleTarTypeBlockCharFifo(path string, stat *types.Stat) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := syscall.Mknod(path, mode, int(mkdev(stat.Devmajor, stat.Devminor))); err != nil {
|
if err := syscall.Mknod(path, mode, int(mkdev(stat.Devmajor, stat.Devminor))); err != nil {
|
||||||
return err
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -77,10 +77,10 @@ func (r *symlinkResolver) readSymlink(p string, allowWildcard bool) ([]string, e
|
||||||
if allowWildcard && containsWildcards(base) {
|
if allowWildcard && containsWildcards(base) {
|
||||||
fis, err := ioutil.ReadDir(filepath.Dir(realPath))
|
fis, err := ioutil.ReadDir(filepath.Dir(realPath))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if os.IsNotExist(err) {
|
if errors.Is(err, os.ErrNotExist) {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
return nil, errors.Wrapf(err, "failed to read dir %s", filepath.Dir(realPath))
|
return nil, errors.Wrap(err, "readdir")
|
||||||
}
|
}
|
||||||
var out []string
|
var out []string
|
||||||
for _, f := range fis {
|
for _, f := range fis {
|
||||||
|
@ -97,17 +97,17 @@ func (r *symlinkResolver) readSymlink(p string, allowWildcard bool) ([]string, e
|
||||||
|
|
||||||
fi, err := os.Lstat(realPath)
|
fi, err := os.Lstat(realPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if os.IsNotExist(err) {
|
if errors.Is(err, os.ErrNotExist) {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
return nil, errors.Wrapf(err, "failed to lstat %s", realPath)
|
return nil, errors.WithStack(err)
|
||||||
}
|
}
|
||||||
if fi.Mode()&os.ModeSymlink == 0 {
|
if fi.Mode()&os.ModeSymlink == 0 {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
link, err := os.Readlink(realPath)
|
link, err := os.Readlink(realPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrapf(err, "failed to readlink %s", realPath)
|
return nil, errors.WithStack(err)
|
||||||
}
|
}
|
||||||
link = filepath.Clean(link)
|
link = filepath.Clean(link)
|
||||||
if filepath.IsAbs(link) {
|
if filepath.IsAbs(link) {
|
||||||
|
|
|
@ -9,6 +9,7 @@ import (
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"github.com/tonistiigi/fsutil/types"
|
"github.com/tonistiigi/fsutil/types"
|
||||||
|
@ -36,7 +37,8 @@ func (fs *fs) Walk(ctx context.Context, fn filepath.WalkFunc) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (fs *fs) Open(p string) (io.ReadCloser, error) {
|
func (fs *fs) Open(p string) (io.ReadCloser, error) {
|
||||||
return os.Open(filepath.Join(fs.root, p))
|
rc, err := os.Open(filepath.Join(fs.root, p))
|
||||||
|
return rc, errors.WithStack(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
type Dir struct {
|
type Dir struct {
|
||||||
|
@ -51,10 +53,10 @@ func SubDirFS(dirs []Dir) (FS, error) {
|
||||||
m := map[string]Dir{}
|
m := map[string]Dir{}
|
||||||
for _, d := range dirs {
|
for _, d := range dirs {
|
||||||
if path.Base(d.Stat.Path) != d.Stat.Path {
|
if path.Base(d.Stat.Path) != d.Stat.Path {
|
||||||
return nil, errors.Errorf("subdir %s must be single file", d.Stat.Path)
|
return nil, errors.WithStack(&os.PathError{Path: d.Stat.Path, Err: syscall.EISDIR, Op: "invalid path"})
|
||||||
}
|
}
|
||||||
if _, ok := m[d.Stat.Path]; ok {
|
if _, ok := m[d.Stat.Path]; ok {
|
||||||
return nil, errors.Errorf("invalid path %s", d.Stat.Path)
|
return nil, errors.WithStack(&os.PathError{Path: d.Stat.Path, Err: syscall.EEXIST, Op: "duplicate path"})
|
||||||
}
|
}
|
||||||
m[d.Stat.Path] = d
|
m[d.Stat.Path] = d
|
||||||
}
|
}
|
||||||
|
@ -70,7 +72,7 @@ func (fs *subDirFS) Walk(ctx context.Context, fn filepath.WalkFunc) error {
|
||||||
for _, d := range fs.dirs {
|
for _, d := range fs.dirs {
|
||||||
fi := &StatInfo{Stat: &d.Stat}
|
fi := &StatInfo{Stat: &d.Stat}
|
||||||
if !fi.IsDir() {
|
if !fi.IsDir() {
|
||||||
return errors.Errorf("fs subdir %s not mode directory", d.Stat.Path)
|
return errors.WithStack(&os.PathError{Path: d.Stat.Path, Err: syscall.ENOTDIR, Op: "walk subdir"})
|
||||||
}
|
}
|
||||||
if err := fn(d.Stat.Path, fi, nil); err != nil {
|
if err := fn(d.Stat.Path, fi, nil); err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -78,7 +80,7 @@ func (fs *subDirFS) Walk(ctx context.Context, fn filepath.WalkFunc) error {
|
||||||
if err := d.FS.Walk(ctx, func(p string, fi os.FileInfo, err error) error {
|
if err := d.FS.Walk(ctx, func(p string, fi os.FileInfo, err error) error {
|
||||||
stat, ok := fi.Sys().(*types.Stat)
|
stat, ok := fi.Sys().(*types.Stat)
|
||||||
if !ok {
|
if !ok {
|
||||||
return errors.Wrapf(err, "invalid fileinfo without stat info: %s", p)
|
return errors.WithStack(&os.PathError{Path: d.Stat.Path, Err: syscall.EBADMSG, Op: "fileinfo without stat info"})
|
||||||
}
|
}
|
||||||
stat.Path = path.Join(d.Stat.Path, stat.Path)
|
stat.Path = path.Join(d.Stat.Path, stat.Path)
|
||||||
if stat.Linkname != "" {
|
if stat.Linkname != "" {
|
||||||
|
@ -105,7 +107,7 @@ func (fs *subDirFS) Open(p string) (io.ReadCloser, error) {
|
||||||
}
|
}
|
||||||
d, ok := fs.m[parts[0]]
|
d, ok := fs.m[parts[0]]
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, os.ErrNotExist
|
return nil, errors.WithStack(&os.PathError{Path: parts[0], Err: syscall.ENOENT, Op: "open"})
|
||||||
}
|
}
|
||||||
return d.FS.Open(parts[1])
|
return d.FS.Open(parts[1])
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,6 +2,7 @@ package fsutil
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"os"
|
"os"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"github.com/tonistiigi/fsutil/types"
|
"github.com/tonistiigi/fsutil/types"
|
||||||
|
@ -28,7 +29,7 @@ func (v *Hardlinks) HandleChange(kind ChangeKind, p string, fi os.FileInfo, err
|
||||||
|
|
||||||
stat, ok := fi.Sys().(*types.Stat)
|
stat, ok := fi.Sys().(*types.Stat)
|
||||||
if !ok {
|
if !ok {
|
||||||
return errors.Errorf("invalid change without stat info: %s", p)
|
return errors.WithStack(&os.PathError{Path: p, Err: syscall.EBADMSG, Op: "change without stat info"})
|
||||||
}
|
}
|
||||||
|
|
||||||
if fi.IsDir() || fi.Mode()&os.ModeSymlink != 0 {
|
if fi.IsDir() || fi.Mode()&os.ModeSymlink != 0 {
|
||||||
|
|
|
@ -5,6 +5,7 @@ import (
|
||||||
"io"
|
"io"
|
||||||
"os"
|
"os"
|
||||||
"sync"
|
"sync"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"github.com/tonistiigi/fsutil/types"
|
"github.com/tonistiigi/fsutil/types"
|
||||||
|
@ -148,7 +149,7 @@ func (s *sender) walk(ctx context.Context) error {
|
||||||
}
|
}
|
||||||
stat, ok := fi.Sys().(*types.Stat)
|
stat, ok := fi.Sys().(*types.Stat)
|
||||||
if !ok {
|
if !ok {
|
||||||
return errors.Wrapf(err, "invalid fileinfo without stat info: %s", path)
|
return errors.WithStack(&os.PathError{Path: path, Err: syscall.EBADMSG, Op: "fileinfo without stat info"})
|
||||||
}
|
}
|
||||||
|
|
||||||
p := &types.Packet{
|
p := &types.Packet{
|
||||||
|
|
|
@ -31,13 +31,13 @@ func mkstat(path, relpath string, fi os.FileInfo, inodemap map[uint64]string) (*
|
||||||
if fi.Mode()&os.ModeSymlink != 0 {
|
if fi.Mode()&os.ModeSymlink != 0 {
|
||||||
link, err := os.Readlink(path)
|
link, err := os.Readlink(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrapf(err, "failed to readlink %s", path)
|
return nil, errors.WithStack(err)
|
||||||
}
|
}
|
||||||
stat.Linkname = link
|
stat.Linkname = link
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if err := loadXattr(path, stat); err != nil {
|
if err := loadXattr(path, stat); err != nil {
|
||||||
return nil, errors.Wrapf(err, "failed to xattr %s", relpath)
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
|
@ -58,7 +58,7 @@ func mkstat(path, relpath string, fi os.FileInfo, inodemap map[uint64]string) (*
|
||||||
func Stat(path string) (*types.Stat, error) {
|
func Stat(path string) (*types.Stat, error) {
|
||||||
fi, err := os.Lstat(path)
|
fi, err := os.Lstat(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, "os stat")
|
return nil, errors.WithStack(err)
|
||||||
}
|
}
|
||||||
return mkstat(path, filepath.Base(path), fi, nil)
|
return mkstat(path, filepath.Base(path), fi, nil)
|
||||||
}
|
}
|
||||||
|
|
|
@ -7,6 +7,7 @@ import (
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"github.com/tonistiigi/fsutil/types"
|
"github.com/tonistiigi/fsutil/types"
|
||||||
|
@ -15,9 +16,12 @@ import (
|
||||||
func WriteTar(ctx context.Context, fs FS, w io.Writer) error {
|
func WriteTar(ctx context.Context, fs FS, w io.Writer) error {
|
||||||
tw := tar.NewWriter(w)
|
tw := tar.NewWriter(w)
|
||||||
err := fs.Walk(ctx, func(path string, fi os.FileInfo, err error) error {
|
err := fs.Walk(ctx, func(path string, fi os.FileInfo, err error) error {
|
||||||
|
if err != nil && !errors.Is(err, os.ErrNotExist) {
|
||||||
|
return err
|
||||||
|
}
|
||||||
stat, ok := fi.Sys().(*types.Stat)
|
stat, ok := fi.Sys().(*types.Stat)
|
||||||
if !ok {
|
if !ok {
|
||||||
return errors.Wrapf(err, "invalid fileinfo without stat info: %s", path)
|
return errors.WithStack(&os.PathError{Path: path, Err: syscall.EBADMSG, Op: "fileinfo without stat info"})
|
||||||
}
|
}
|
||||||
hdr, err := tar.FileInfoHeader(fi, stat.Linkname)
|
hdr, err := tar.FileInfoHeader(fi, stat.Linkname)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -52,7 +56,7 @@ func WriteTar(ctx context.Context, fs FS, w io.Writer) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := tw.WriteHeader(hdr); err != nil {
|
if err := tw.WriteHeader(hdr); err != nil {
|
||||||
return errors.Wrap(err, "failed to write file header")
|
return errors.Wrapf(err, "failed to write file header %s", name)
|
||||||
}
|
}
|
||||||
|
|
||||||
if hdr.Typeflag == tar.TypeReg && hdr.Size > 0 && hdr.Linkname == "" {
|
if hdr.Typeflag == tar.TypeReg && hdr.Size > 0 && hdr.Linkname == "" {
|
||||||
|
@ -61,10 +65,10 @@ func WriteTar(ctx context.Context, fs FS, w io.Writer) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if _, err := io.Copy(tw, rc); err != nil {
|
if _, err := io.Copy(tw, rc); err != nil {
|
||||||
return err
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
if err := rc.Close(); err != nil {
|
if err := rc.Close(); err != nil {
|
||||||
return err
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
|
|
@ -6,6 +6,7 @@ import (
|
||||||
"runtime"
|
"runtime"
|
||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
)
|
)
|
||||||
|
@ -31,10 +32,10 @@ func (v *Validator) HandleChange(kind ChangeKind, p string, fi os.FileInfo, err
|
||||||
p = strings.Replace(p, "\\", "", -1)
|
p = strings.Replace(p, "\\", "", -1)
|
||||||
}
|
}
|
||||||
if p != path.Clean(p) {
|
if p != path.Clean(p) {
|
||||||
return errors.Errorf("invalid unclean path %s", p)
|
return errors.WithStack(&os.PathError{Path: p, Err: syscall.EINVAL, Op: "unclean path"})
|
||||||
}
|
}
|
||||||
if path.IsAbs(p) {
|
if path.IsAbs(p) {
|
||||||
return errors.Errorf("abolute path %s not allowed", p)
|
return errors.WithStack(&os.PathError{Path: p, Err: syscall.EINVAL, Op: "absolute path"})
|
||||||
}
|
}
|
||||||
dir := path.Dir(p)
|
dir := path.Dir(p)
|
||||||
base := path.Base(p)
|
base := path.Base(p)
|
||||||
|
@ -42,7 +43,7 @@ func (v *Validator) HandleChange(kind ChangeKind, p string, fi os.FileInfo, err
|
||||||
dir = ""
|
dir = ""
|
||||||
}
|
}
|
||||||
if dir == ".." || strings.HasPrefix(p, "../") {
|
if dir == ".." || strings.HasPrefix(p, "../") {
|
||||||
return errors.Errorf("invalid path: %s", p)
|
return errors.WithStack(&os.PathError{Path: p, Err: syscall.EINVAL, Op: "escape check"})
|
||||||
}
|
}
|
||||||
|
|
||||||
// find a parent dir from saved records
|
// find a parent dir from saved records
|
||||||
|
|
|
@ -25,21 +25,21 @@ type WalkOpt struct {
|
||||||
func Walk(ctx context.Context, p string, opt *WalkOpt, fn filepath.WalkFunc) error {
|
func Walk(ctx context.Context, p string, opt *WalkOpt, fn filepath.WalkFunc) error {
|
||||||
root, err := filepath.EvalSymlinks(p)
|
root, err := filepath.EvalSymlinks(p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrapf(err, "failed to resolve %s", root)
|
return errors.WithStack(&os.PathError{Op: "resolve", Path: root, Err: err})
|
||||||
}
|
}
|
||||||
fi, err := os.Stat(root)
|
fi, err := os.Stat(root)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrapf(err, "failed to stat: %s", root)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
if !fi.IsDir() {
|
if !fi.IsDir() {
|
||||||
return errors.Errorf("%s is not a directory", root)
|
return errors.WithStack(&os.PathError{Op: "walk", Path: root, Err: syscall.ENOTDIR})
|
||||||
}
|
}
|
||||||
|
|
||||||
var pm *fileutils.PatternMatcher
|
var pm *fileutils.PatternMatcher
|
||||||
if opt != nil && opt.ExcludePatterns != nil {
|
if opt != nil && opt.ExcludePatterns != nil {
|
||||||
pm, err = fileutils.NewPatternMatcher(opt.ExcludePatterns)
|
pm, err = fileutils.NewPatternMatcher(opt.ExcludePatterns)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrapf(err, "invalid excludepaths %s", opt.ExcludePatterns)
|
return errors.Wrapf(err, "invalid excludepatterns: %s", opt.ExcludePatterns)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -65,17 +65,15 @@ func Walk(ctx context.Context, p string, opt *WalkOpt, fn filepath.WalkFunc) err
|
||||||
|
|
||||||
seenFiles := make(map[uint64]string)
|
seenFiles := make(map[uint64]string)
|
||||||
return filepath.Walk(root, func(path string, fi os.FileInfo, err error) (retErr error) {
|
return filepath.Walk(root, func(path string, fi os.FileInfo, err error) (retErr error) {
|
||||||
if err != nil {
|
|
||||||
if os.IsNotExist(err) {
|
|
||||||
return filepath.SkipDir
|
|
||||||
}
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
defer func() {
|
defer func() {
|
||||||
if retErr != nil && isNotExist(retErr) {
|
if retErr != nil && isNotExist(retErr) {
|
||||||
retErr = filepath.SkipDir
|
retErr = filepath.SkipDir
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
origpath := path
|
origpath := path
|
||||||
path, err = filepath.Rel(root, path)
|
path, err = filepath.Rel(root, path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -297,7 +297,7 @@ github.com/stretchr/testify/assert
|
||||||
github.com/stretchr/testify/require
|
github.com/stretchr/testify/require
|
||||||
# github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2
|
# github.com/syndtr/gocapability v0.0.0-20180916011248-d98352740cb2
|
||||||
github.com/syndtr/gocapability/capability
|
github.com/syndtr/gocapability/capability
|
||||||
# github.com/tonistiigi/fsutil v0.0.0-20200512175118-ae3a8d753069
|
# github.com/tonistiigi/fsutil v0.0.0-20200720184806-8f851f9d2045
|
||||||
github.com/tonistiigi/fsutil
|
github.com/tonistiigi/fsutil
|
||||||
github.com/tonistiigi/fsutil/copy
|
github.com/tonistiigi/fsutil/copy
|
||||||
github.com/tonistiigi/fsutil/types
|
github.com/tonistiigi/fsutil/types
|
||||||
|
|
Loading…
Reference in New Issue