Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for erasureDisks (0.09 sec)

  1. cmd/erasure-object_test.go

    		for i := 0; i <= f; i++ {
    			diskErrors[i] = nil
    		}
    		erasureDisks := xl.getDisks()
    		for i := range erasureDisks[:9] {
    			switch diskType := erasureDisks[i].(type) {
    			case *naughtyDisk:
    				erasureDisks[i] = newNaughtyDisk(diskType.disk, diskErrors, errFaultyDisk)
    			default:
    				erasureDisks[i] = newNaughtyDisk(erasureDisks[i], diskErrors, errFaultyDisk)
    			}
    		}
    		z.serverPools[0].erasureDisksMu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common_test.go

    				if errs[j] != nil {
    					t.Fatalf("expected error to be nil: %s", errs[j])
    				}
    				partsMetadata[j].ModTime = test.modTimes[j]
    			}
    
    			if erasureDisks, err = writeUniqueFileInfo(ctx, erasureDisks, "", bucket, object, partsMetadata, diskCount(erasureDisks)); err != nil {
    				t.Fatal(ctx, err)
    			}
    
    			tamperedIndex := -1
    			switch test._tamperBackend {
    			case deletePart:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    // current design.
    type erasureSets struct {
    	sets []*erasureObjects
    
    	// Reference format.
    	format *formatErasureV3
    
    	// erasureDisks mutex to lock erasureDisks.
    	erasureDisksMu sync.RWMutex
    
    	// Re-ordered list of disks per set.
    	erasureDisks [][]StorageAPI
    
    	// Distributed locker clients.
    	erasureLockers setsDsyncLockers
    
    	// Distributed lock owner (constant per running instance).
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  4. cmd/object-api-utils_test.go

    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false)
    	for i := range parts {
    		if errs[i] == nil {
    			if parts[i].Name == objectName {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  5. cmd/post-policy_test.go

    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName+"/upload.txt", "", false, false)
    	for i := range parts {
    		if errs[i] == nil {
    			if parts[i].Name == objectName+"/upload.txt" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top