Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetDisks (0.06 sec)

  1. cmd/erasure-healing_test.go

    		return disk
    	}
    
    	// Remove 4 disks.
    	setDisks(nil, nil, nil, nil)
    
    	// Create delete marker under quorum.
    	objInfo, err := objLayer.DeleteObject(ctx, bucket, object, ObjectOptions{Versioned: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Restore...
    	setDisks(orgDisks[:4]...)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    	// Read metadata associated with the object from all disks.
    	storageDisks := er.getDisks()
    
    	var metaArr []FileInfo
    	var errs []error
    
    	// Read metadata associated with the object from all disks.
    	if srcOpts.VersionID != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/object-api-multipart_test.go

    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	erasureDisks := er.getDisks()
    	ridx := rand.Intn(len(erasureDisks))
    
    	z.serverPools[0].erasureDisksMu.Lock()
    	er.getDisks = func() []StorageAPI {
    		erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk)
    		return erasureDisks
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    	}
    	return nil
    }
    
    // Return the disks belonging to the poolIdx, and setIdx.
    func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) {
    	if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) {
    		return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil
    	}
    	return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1))
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    		return nil, nil, err
    	}
    
    	var formattedDisks []StorageAPI
    	// Should use the object layer tests for validating cache.
    	if z, ok := objLayer.(*erasureServerPools); ok {
    		formattedDisks = z.serverPools[0].GetDisks(0)()
    	}
    
    	// Success.
    	return objLayer, formattedDisks, nil
    }
    
    // removeRoots - Cleans up initialized directories during tests.
    func removeRoots(roots []string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	objAPI := newObjectLayerFn()
    	// object layer not initialized, return.
    	if objAPI == nil {
    		return cache, errServerNotInitialized
    	}
    
    	poolIdx, setIdx, _ := s.GetDiskLoc()
    
    	disks, err := objAPI.GetDisks(poolIdx, setIdx)
    	if err != nil {
    		return cache, err
    	}
    
    	cache.Info.updates = updates
    
    	dataUsageInfo, err := scanDataFolder(ctx, disks, s, cache, func(item scannerItem) (sizeSummary, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top