- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for fsDirs (0.07 sec)
-
cmd/erasure-object_test.go
const numDisks = 4 path := t.TempDir() var fsDirs []string for i := 1; i <= numDisks; i++ { fsDirs = append(fsDirs, filepath.Join(path, fmt.Sprintf("disk%d", i))) } objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...)) if err != nil { removeRoots(fsDirs) t.Fatal(err) } // cleaning up of temporary test directories
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.3K bytes - Viewed (0) -
cmd/erasure-healing_test.go
defer cancel() resetGlobalHealState() defer resetGlobalHealState() nDisks := 32 fsDirs, err := getRandomDisks(nDisks) if err != nil { t.Fatal(err) } defer removeRoots(fsDirs) pools := mustGetPoolEndpoints(0, fsDirs[:16]...) pools = append(pools, mustGetPoolEndpoints(1, fsDirs[16:]...)...) // Everything is fine, should return nil objLayer, _, err := initObjectLayer(ctx, pools)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
cmd/format-erasure_test.go
benchmarkInitStorageDisksN(b, 32*204) } func benchmarkInitStorageDisksN(b *testing.B, nDisks int) { b.ResetTimer() b.ReportAllocs() fsDirs, err := getRandomDisks(nDisks) if err != nil { b.Fatal(err) } endpoints := mustGetNewEndpoints(0, 16, fsDirs...) b.RunParallel(func(pb *testing.PB) { endpoints := endpoints for pb.Next() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12.7K bytes - Viewed (0) -
cmd/auth-handler_test.go
func TestIsReqAuthenticated(t *testing.T) { ctx, cancel := context.WithCancel(GlobalContext) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) } initAllSubsystems(ctx)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 15.4K bytes - Viewed (0) -
cmd/signature-v4_test.go
} return fmt.Sprintf("%s (%s)", errorCodes[code].Code, errorCodes[code].Description) } func TestDoesPolicySignatureMatch(t *testing.T) { _, fsDir, err := prepareFS(t.Context()) if err != nil { t.Fatal(err) } defer removeRoots([]string{fsDir}) credentialTemplate := "%s/%s/%s/s3/aws4_request" now := UTCNow() accessKey := globalActiveCred.AccessKey testCases := []struct { form http.Header
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 10.5K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
xhttp "github.com/minio/minio/internal/http" ) func TestCheckValid(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) } initAllSubsystems(ctx)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 14.3K bytes - Viewed (0)