aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--test/fuse_integration/concurrent_operations_test.go5
-rw-r--r--test/fuse_integration/directory_operations_test.go2
-rw-r--r--test/fuse_integration/framework.go2
-rw-r--r--test/fuse_integration/go.mod13
-rw-r--r--test/fuse_integration/go.sum10
-rw-r--r--test/fuse_integration/minimal_test.go2
-rw-r--r--test/fuse_integration/posix_compliance_test.go2
-rw-r--r--test/fuse_integration/posix_extended_test.go53
-rw-r--r--test/fuse_integration/posix_external_test.go2
-rw-r--r--test/fuse_integration/simple_test.go2
-rw-r--r--test/fuse_integration/working_demo_test.go2
11 files changed, 12 insertions, 83 deletions
diff --git a/test/fuse_integration/concurrent_operations_test.go b/test/fuse_integration/concurrent_operations_test.go
index 7a5cdd0d3..6bbc43532 100644
--- a/test/fuse_integration/concurrent_operations_test.go
+++ b/test/fuse_integration/concurrent_operations_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"bytes"
@@ -394,6 +394,9 @@ func testHighFrequencySmallWrites(t *testing.T, framework *FuseTestFramework) {
}
file.Close()
+ // Calculate expected total size
+ totalSize := int64(numWrites * writeSize)
+
// Verify file size
info, err := os.Stat(mountPath)
require.NoError(t, err)
diff --git a/test/fuse_integration/directory_operations_test.go b/test/fuse_integration/directory_operations_test.go
index 060a3a027..6c03d4fc0 100644
--- a/test/fuse_integration/directory_operations_test.go
+++ b/test/fuse_integration/directory_operations_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"fmt"
diff --git a/test/fuse_integration/framework.go b/test/fuse_integration/framework.go
index 82b5e3459..32bcb97a9 100644
--- a/test/fuse_integration/framework.go
+++ b/test/fuse_integration/framework.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"fmt"
diff --git a/test/fuse_integration/go.mod b/test/fuse_integration/go.mod
deleted file mode 100644
index 528303465..000000000
--- a/test/fuse_integration/go.mod
+++ /dev/null
@@ -1,13 +0,0 @@
-module seaweedfs-posix-tests
-
-go 1.21
-
-require (
- github.com/stretchr/testify v1.9.0
-)
-
-require (
- github.com/davecgh/go-spew v1.1.1 // indirect
- github.com/pmezard/go-difflib v1.0.0 // indirect
- gopkg.in/yaml.v3 v3.0.1 // indirect
-) \ No newline at end of file
diff --git a/test/fuse_integration/go.sum b/test/fuse_integration/go.sum
deleted file mode 100644
index fa4b6e682..000000000
--- a/test/fuse_integration/go.sum
+++ /dev/null
@@ -1,10 +0,0 @@
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
-github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
-gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/test/fuse_integration/minimal_test.go b/test/fuse_integration/minimal_test.go
index 8d849fe77..0c84a232b 100644
--- a/test/fuse_integration/minimal_test.go
+++ b/test/fuse_integration/minimal_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import "testing"
diff --git a/test/fuse_integration/posix_compliance_test.go b/test/fuse_integration/posix_compliance_test.go
index 9a9fb152f..85d126ede 100644
--- a/test/fuse_integration/posix_compliance_test.go
+++ b/test/fuse_integration/posix_compliance_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"fmt"
diff --git a/test/fuse_integration/posix_extended_test.go b/test/fuse_integration/posix_extended_test.go
index 4019930fe..eb1ddc0c0 100644
--- a/test/fuse_integration/posix_extended_test.go
+++ b/test/fuse_integration/posix_extended_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"os"
@@ -60,10 +60,6 @@ func (s *POSIXExtendedTestSuite) TestExtendedAttributes(t *testing.T) {
err := os.WriteFile(testFile, []byte("xattr test"), 0644)
require.NoError(t, err)
- // Set extended attribute
- attrName := "user.test_attr"
- attrValue := []byte("test_value")
-
// Extended attributes test - platform dependent
t.Skip("Extended attributes testing requires platform-specific implementation")
})
@@ -75,13 +71,6 @@ func (s *POSIXExtendedTestSuite) TestExtendedAttributes(t *testing.T) {
err := os.WriteFile(testFile, []byte("list xattr test"), 0644)
require.NoError(t, err)
- // Set multiple extended attributes
- attrs := map[string][]byte{
- "user.attr1": []byte("value1"),
- "user.attr2": []byte("value2"),
- "user.attr3": []byte("value3"),
- }
-
// List extended attributes test - platform dependent
t.Skip("Extended attributes testing requires platform-specific implementation")
})
@@ -93,9 +82,6 @@ func (s *POSIXExtendedTestSuite) TestExtendedAttributes(t *testing.T) {
err := os.WriteFile(testFile, []byte("remove xattr test"), 0644)
require.NoError(t, err)
- attrName := "user.removeme"
- attrValue := []byte("to_be_removed")
-
// Remove extended attributes test - platform dependent
t.Skip("Extended attributes testing requires platform-specific implementation")
})
@@ -204,17 +190,6 @@ func (s *POSIXExtendedTestSuite) TestAdvancedIO(t *testing.T) {
require.NoError(t, err)
defer syscall.Close(fd)
- // Prepare multiple buffers for writev
- buf1 := []byte("first")
- buf2 := []byte("second")
- buf3 := []byte("third")
-
- iovecs := []syscall.Iovec{
- {Base: &buf1[0], Len: uint64(len(buf1))},
- {Base: &buf2[0], Len: uint64(len(buf2))},
- {Base: &buf3[0], Len: uint64(len(buf3))},
- }
-
// Vectored I/O test - requires platform-specific implementation
t.Skip("Vectored I/O testing requires platform-specific implementation")
})
@@ -382,35 +357,9 @@ func (s *POSIXExtendedTestSuite) TestMemoryMapping(t *testing.T) {
// TestDirectIO tests direct I/O operations
func (s *POSIXExtendedTestSuite) TestDirectIO(t *testing.T) {
- mountPoint := s.framework.GetMountPoint()
-
t.Run("DirectIO", func(t *testing.T) {
- testFile := filepath.Join(mountPoint, "direct_io_test.txt")
-
// Direct I/O is platform dependent and may not be supported
t.Skip("Direct I/O testing requires platform-specific implementation")
-
- // For direct I/O, buffer must be aligned
- const blockSize = 4096
- alignedBuffer := make([]byte, blockSize)
- for i := range alignedBuffer {
- alignedBuffer[i] = byte(i % 256)
- }
-
- // Write with direct I/O
- n, err := syscall.Write(fd, alignedBuffer)
- require.NoError(t, err)
- require.Equal(t, blockSize, n)
-
- // Read back with direct I/O
- _, err = syscall.Seek(fd, 0, 0)
- require.NoError(t, err)
-
- readBuffer := make([]byte, blockSize)
- n, err = syscall.Read(fd, readBuffer)
- require.NoError(t, err)
- require.Equal(t, blockSize, n)
- require.Equal(t, alignedBuffer, readBuffer)
})
}
diff --git a/test/fuse_integration/posix_external_test.go b/test/fuse_integration/posix_external_test.go
index b29047c8c..6d8cd60ba 100644
--- a/test/fuse_integration/posix_external_test.go
+++ b/test/fuse_integration/posix_external_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"bufio"
diff --git a/test/fuse_integration/simple_test.go b/test/fuse_integration/simple_test.go
index a82157181..3fdf82f7f 100644
--- a/test/fuse_integration/simple_test.go
+++ b/test/fuse_integration/simple_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"testing"
diff --git a/test/fuse_integration/working_demo_test.go b/test/fuse_integration/working_demo_test.go
index 483288f9f..408342016 100644
--- a/test/fuse_integration/working_demo_test.go
+++ b/test/fuse_integration/working_demo_test.go
@@ -1,4 +1,4 @@
-package fuse_test
+package fuse
import (
"os"