mirror of
https://github.com/rclone/rclone.git
synced 2025-03-11 05:25:14 +08:00
401cf81034
This commit modernizes Go usage. This was done with:
go run golang.org/x/tools/gopls/internal/analysis/modernize/cmd/modernize@latest -fix -test ./...
Then files needed to be `go fmt`ed and a few comments needed to be
restored.
The modernizations include replacing
- if/else conditional assignment by a call to the built-in min or max functions added in go1.21
- sort.Slice(x, func(i, j int) bool) { return s[i] < s[j] } by a call to slices.Sort(s), added in go1.21
- interface{} by the 'any' type added in go1.18
- append([]T(nil), s...) by slices.Clone(s) or slices.Concat(s), added in go1.21
- loop around an m[k]=v map update by a call to one of the Collect, Copy, Clone, or Insert functions from the maps package, added in go1.21
- []byte(fmt.Sprintf...) by fmt.Appendf(nil, ...), added in go1.19
- append(s[:i], s[i+1]...) by slices.Delete(s, i, i+1), added in go1.21
- a 3-clause for i := 0; i < n; i++ {} loop by for i := range n {}, added in go1.22
124 lines
2.7 KiB
Go
124 lines
2.7 KiB
Go
package vfstest
|
|
|
|
import (
|
|
"io"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
// TestReadByByte reads by byte including don't read any bytes
|
|
func TestReadByByte(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
var data = []byte("hellohello")
|
|
run.createFile(t, "testfile", string(data))
|
|
run.checkDir(t, "testfile 10")
|
|
|
|
for i := range data {
|
|
fd, err := run.os.Open(run.path("testfile"))
|
|
assert.NoError(t, err)
|
|
for j := range i {
|
|
buf := make([]byte, 1)
|
|
n, err := io.ReadFull(fd, buf)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, 1, n)
|
|
assert.Equal(t, buf[0], data[j])
|
|
}
|
|
err = fd.Close()
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
run.rm(t, "testfile")
|
|
}
|
|
|
|
// TestReadChecksum checks the checksum reading is working
|
|
func TestReadChecksum(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
// create file big enough so we exceed any single FUSE read
|
|
// request
|
|
b := make([]rune, 3*128*1024)
|
|
for i := range b {
|
|
b[i] = 'r'
|
|
}
|
|
run.createFile(t, "bigfile", string(b))
|
|
|
|
// The hash comparison would fail in Flush, if we did not
|
|
// ensure we read the whole file
|
|
fd, err := run.os.Open(run.path("bigfile"))
|
|
assert.NoError(t, err)
|
|
buf := make([]byte, 10)
|
|
_, err = io.ReadFull(fd, buf)
|
|
assert.NoError(t, err)
|
|
err = fd.Close()
|
|
assert.NoError(t, err)
|
|
|
|
// The hash comparison would fail, because we only read parts
|
|
// of the file
|
|
fd, err = run.os.Open(run.path("bigfile"))
|
|
assert.NoError(t, err)
|
|
// read at start
|
|
_, err = io.ReadFull(fd, buf)
|
|
assert.NoError(t, err)
|
|
// read at end
|
|
_, err = fd.Seek(int64(len(b)-len(buf)), io.SeekStart)
|
|
assert.NoError(t, err)
|
|
_, err = io.ReadFull(fd, buf)
|
|
assert.NoError(t, err)
|
|
// ensure we don't compare hashes
|
|
err = fd.Close()
|
|
assert.NoError(t, err)
|
|
|
|
run.rm(t, "bigfile")
|
|
}
|
|
|
|
// TestReadSeek test seeking
|
|
func TestReadSeek(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
var data = []byte("helloHELLO")
|
|
run.createFile(t, "testfile", string(data))
|
|
run.checkDir(t, "testfile 10")
|
|
|
|
fd, err := run.os.Open(run.path("testfile"))
|
|
assert.NoError(t, err)
|
|
|
|
// Seek to half way
|
|
_, err = fd.Seek(5, io.SeekStart)
|
|
assert.NoError(t, err)
|
|
|
|
buf, err := io.ReadAll(fd)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, buf, []byte("HELLO"))
|
|
|
|
// Test seeking to the end
|
|
_, err = fd.Seek(10, io.SeekStart)
|
|
assert.NoError(t, err)
|
|
|
|
buf, err = io.ReadAll(fd)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, buf, []byte(""))
|
|
|
|
// Test seeking beyond the end
|
|
_, err = fd.Seek(1000000, io.SeekStart)
|
|
assert.NoError(t, err)
|
|
|
|
buf, err = io.ReadAll(fd)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, buf, []byte(""))
|
|
|
|
// Now back to the start
|
|
_, err = fd.Seek(0, io.SeekStart)
|
|
assert.NoError(t, err)
|
|
|
|
buf, err = io.ReadAll(fd)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, buf, []byte("helloHELLO"))
|
|
|
|
err = fd.Close()
|
|
assert.NoError(t, err)
|
|
|
|
run.rm(t, "testfile")
|
|
}
|