diff options
| author | Robert Coelho <me@iscoelho.com> | 2022-05-24 13:02:59 -0400 |
|---|---|---|
| committer | Robert Coelho <me@iscoelho.com> | 2022-05-24 13:02:59 -0400 |
| commit | 0e6e72d46263a7041606a28edbd8285b4bbf900c (patch) | |
| tree | f208b710984346a3c424819cbe84997d0d1d67e6 /weed/mount/weedfs_dir_read.go | |
| parent | 1fabbe8a25f8cd4183589f728dcf9a5031905b2d (diff) | |
| download | seaweedfs-0e6e72d46263a7041606a28edbd8285b4bbf900c.tar.xz seaweedfs-0e6e72d46263a7041606a28edbd8285b4bbf900c.zip | |
mount: ReadDir return EIO on EnsureVisited err
Diffstat (limited to 'weed/mount/weedfs_dir_read.go')
| -rw-r--r-- | weed/mount/weedfs_dir_read.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/mount/weedfs_dir_read.go b/weed/mount/weedfs_dir_read.go index 6e65bec13..1baa68fa2 100644 --- a/weed/mount/weedfs_dir_read.go +++ b/weed/mount/weedfs_dir_read.go @@ -221,6 +221,7 @@ func (wfs *WFS) doReadDirectory(input *fuse.ReadIn, out *fuse.DirEntryList, isPl var err error if err = meta_cache.EnsureVisited(wfs.metaCache, wfs, dirPath, nil); err != nil { glog.Errorf("dir ReadDirAll %s: %v", dirPath, err) + return fuse.EIO } listErr := wfs.metaCache.ListDirectoryEntries(context.Background(), dirPath, lastEntryName, false, int64(math.MaxInt32), func(entry *filer.Entry) bool { dh.entryStream = append(dh.entryStream, entry) |