mirror of
https://github.com/rclone/rclone
synced 2024-12-02 11:53:45 +01:00
4a382c09ec
Before this change we ran the tests and the mount in the same process. This could cause deadlocks and often did, and made the mount tests very unreliable. This fixes the problem by running the mount in a seperate process and commanding it via a pipe over stdin/stdout.
70 lines
1.5 KiB
Go
70 lines
1.5 KiB
Go
//go:build linux || darwin || freebsd
|
|
// +build linux darwin freebsd
|
|
|
|
package vfstest
|
|
|
|
import (
|
|
"runtime"
|
|
"testing"
|
|
|
|
"github.com/rclone/rclone/vfs/vfscommon"
|
|
"github.com/stretchr/testify/assert"
|
|
"golang.org/x/sys/unix"
|
|
)
|
|
|
|
// TestWriteFileDoubleClose tests double close on write
|
|
func TestWriteFileDoubleClose(t *testing.T) {
|
|
run.skipIfVFS(t)
|
|
run.skipIfNoFUSE(t)
|
|
if runtime.GOOS == "darwin" {
|
|
t.Skip("Skipping test on OSX")
|
|
}
|
|
|
|
out, err := osCreate(run.path("testdoubleclose"))
|
|
assert.NoError(t, err)
|
|
fd := out.Fd()
|
|
|
|
fd1, err := unix.Dup(int(fd))
|
|
assert.NoError(t, err)
|
|
|
|
fd2, err := unix.Dup(int(fd))
|
|
assert.NoError(t, err)
|
|
|
|
// close one of the dups - should produce no error
|
|
err = unix.Close(fd1)
|
|
assert.NoError(t, err)
|
|
|
|
// write to the file
|
|
buf := []byte("hello")
|
|
n, err := out.Write(buf)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, 5, n)
|
|
|
|
// close it
|
|
err = out.Close()
|
|
assert.NoError(t, err)
|
|
|
|
// write to the other dup
|
|
_, err = unix.Write(fd2, buf)
|
|
if run.vfsOpt.CacheMode < vfscommon.CacheModeWrites {
|
|
// produces an error if cache mode < writes
|
|
assert.Error(t, err, "input/output error")
|
|
} else {
|
|
// otherwise does not produce an error
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
// close the dup - should not produce an error
|
|
err = unix.Close(fd2)
|
|
assert.NoError(t, err)
|
|
|
|
run.waitForWriters()
|
|
run.rm(t, "testdoubleclose")
|
|
}
|
|
|
|
// writeTestDup performs the platform-specific implementation of the dup() unix
|
|
func writeTestDup(oldfd uintptr) (uintptr, error) {
|
|
newfd, err := unix.Dup(int(oldfd))
|
|
return uintptr(newfd), err
|
|
}
|