123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165 |
- // Copyright (C) 2017 The Syncthing Authors.
- //
- // This Source Code Form is subject to the terms of the Mozilla Public
- // License, v. 2.0. If a copy of the MPL was not distributed with this file,
- // You can obtain one at https://mozilla.org/MPL/2.0/.
- package scanner
- import (
- "errors"
- "fmt"
- "io"
- "path/filepath"
- "strings"
- "time"
- "github.com/syncthing/syncthing/lib/fs"
- "github.com/syncthing/syncthing/lib/protocol"
- )
- type infiniteFS struct {
- fs.Filesystem
- width int // number of files and directories per level
- depth int // number of tree levels to simulate
- filesize int64 // size of each file in bytes
- }
- var errNotSupp = errors.New("not supported")
- func (i infiniteFS) Lstat(name string) (fs.FileInfo, error) {
- return fakeInfo{name, i.filesize}, nil
- }
- func (i infiniteFS) Stat(name string) (fs.FileInfo, error) {
- return fakeInfo{name, i.filesize}, nil
- }
- func (i infiniteFS) DirNames(name string) ([]string, error) {
- // Returns a list of fake files and directories. Names are such that
- // files appear before directories - this makes it so the scanner will
- // actually see a few files without having to reach the max depth.
- var names []string
- for j := 0; j < i.width; j++ {
- names = append(names, fmt.Sprintf("aa-file-%d", j))
- }
- if len(fs.PathComponents(name)) < i.depth {
- for j := 0; j < i.width; j++ {
- names = append(names, fmt.Sprintf("zz-dir-%d", j))
- }
- }
- return names, nil
- }
- func (i infiniteFS) Open(name string) (fs.File, error) {
- return &fakeFile{name, i.filesize, 0}, nil
- }
- func (infiniteFS) PlatformData(_ string, _, _ bool, _ fs.XattrFilter) (protocol.PlatformData, error) {
- return protocol.PlatformData{}, nil
- }
- type singleFileFS struct {
- fs.Filesystem
- name string
- filesize int64
- }
- func (s singleFileFS) Lstat(name string) (fs.FileInfo, error) {
- switch name {
- case ".":
- return fakeInfo{".", 0}, nil
- case s.name:
- return fakeInfo{s.name, s.filesize}, nil
- default:
- return nil, errors.New("no such file")
- }
- }
- func (s singleFileFS) Stat(name string) (fs.FileInfo, error) {
- switch name {
- case ".":
- return fakeInfo{".", 0}, nil
- case s.name:
- return fakeInfo{s.name, s.filesize}, nil
- default:
- return nil, errors.New("no such file")
- }
- }
- func (s singleFileFS) DirNames(name string) ([]string, error) {
- if name != "." {
- return nil, errors.New("no such file")
- }
- return []string{s.name}, nil
- }
- func (s singleFileFS) Open(name string) (fs.File, error) {
- if name != s.name {
- return nil, errors.New("no such file")
- }
- return &fakeFile{s.name, s.filesize, 0}, nil
- }
- func (singleFileFS) Options() []fs.Option {
- return nil
- }
- func (singleFileFS) PlatformData(_ string, _, _ bool, _ fs.XattrFilter) (protocol.PlatformData, error) {
- return protocol.PlatformData{}, nil
- }
- type fakeInfo struct {
- name string
- size int64
- }
- func (f fakeInfo) Name() string { return f.name }
- func (fakeInfo) Mode() fs.FileMode { return 0o755 }
- func (f fakeInfo) Size() int64 { return f.size }
- func (fakeInfo) ModTime() time.Time { return time.Unix(1234567890, 0) }
- func (f fakeInfo) IsDir() bool {
- return strings.Contains(filepath.Base(f.name), "dir") || f.name == "."
- }
- func (f fakeInfo) IsRegular() bool { return !f.IsDir() }
- func (fakeInfo) IsSymlink() bool { return false }
- func (fakeInfo) Owner() int { return 0 }
- func (fakeInfo) Group() int { return 0 }
- func (fakeInfo) Sys() interface{} { return nil }
- func (fakeInfo) InodeChangeTime() time.Time { return time.Time{} }
- type fakeFile struct {
- name string
- size int64
- readOffset int64
- }
- func (f *fakeFile) Name() string {
- return f.name
- }
- func (f *fakeFile) Read(bs []byte) (int, error) {
- remaining := f.size - f.readOffset
- if remaining == 0 {
- return 0, io.EOF
- }
- if remaining < int64(len(bs)) {
- f.readOffset = f.size
- return int(remaining), nil
- }
- f.readOffset += int64(len(bs))
- return len(bs), nil
- }
- func (f *fakeFile) Stat() (fs.FileInfo, error) {
- return fakeInfo{f.name, f.size}, nil
- }
- func (*fakeFile) Write([]byte) (int, error) { return 0, errNotSupp }
- func (*fakeFile) WriteAt([]byte, int64) (int, error) { return 0, errNotSupp }
- func (*fakeFile) Close() error { return nil }
- func (*fakeFile) Truncate(_ int64) error { return errNotSupp }
- func (*fakeFile) ReadAt([]byte, int64) (int, error) { return 0, errNotSupp }
- func (*fakeFile) Seek(int64, int) (int64, error) { return 0, errNotSupp }
- func (*fakeFile) Sync() error { return nil }
|