aboutsummaryrefslogtreecommitdiff
path: root/test/fuse_integration/posix_external_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'test/fuse_integration/posix_external_test.go')
-rw-r--r--test/fuse_integration/posix_external_test.go23
1 files changed, 16 insertions, 7 deletions
diff --git a/test/fuse_integration/posix_external_test.go b/test/fuse_integration/posix_external_test.go
index c6c02a061..a90eb6bcd 100644
--- a/test/fuse_integration/posix_external_test.go
+++ b/test/fuse_integration/posix_external_test.go
@@ -10,6 +10,7 @@ import (
"testing"
"time"
+ "github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
)
@@ -356,7 +357,9 @@ func (s *ExternalPOSIXTestSuite) stressTestRename(t *testing.T, mountPoint strin
for i := 0; i < numFiles; i++ {
fileName := filepath.Join(testDir, fmt.Sprintf("file_%d.txt", i))
err := os.WriteFile(fileName, []byte(fmt.Sprintf("content_%d", i)), 0644)
- require.NoError(t, err)
+ if !assert.NoError(t, err, "Failed to create initial file %d", i) {
+ return // Skip test if setup fails
+ }
}
// Concurrent rename operations
@@ -376,16 +379,22 @@ func (s *ExternalPOSIXTestSuite) stressTestRename(t *testing.T, mountPoint strin
}(w)
}
- // Wait for all workers
+ // Wait for all workers and collect errors
+ var errorCount int
for w := 0; w < numWorkers; w++ {
err := <-results
- require.NoError(t, err)
+ if err != nil {
+ assert.NoError(t, err, "Worker %d failed", w)
+ errorCount++
+ }
}
- // Verify all files were renamed
- files, err := filepath.Glob(filepath.Join(testDir, "renamed_*.txt"))
- require.NoError(t, err)
- require.Equal(t, numFiles, len(files))
+ // Verify all files were renamed (if no errors occurred)
+ if errorCount == 0 {
+ files, err := filepath.Glob(filepath.Join(testDir, "renamed_*.txt"))
+ assert.NoError(t, err, "Failed to list renamed files")
+ assert.Equal(t, numFiles, len(files), "Not all files were renamed successfully")
+ }
}
// stressTestCreate tests file creation under stress