Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for onlineDisks (0.19 sec)

  1. cmd/erasure-object.go

    	if dataDir == "" {
    		return nil
    	}
    	g := errgroup.WithNErrs(len(onlineDisks))
    	for index := range onlineDisks {
    		index := index
    		g.Go(func() error {
    			if onlineDisks[index] == nil {
    				return nil
    			}
    			return onlineDisks[index].Delete(ctx, bucket, pathJoin(object, dataDir), DeleteOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. cmd/erasure-multipart.go

    		// Check if there is any offline disk and add it to the MRF list
    		for _, disk := range onlineDisks {
    			if disk != nil && disk.IsOnline() {
    				continue
    			}
    			er.addPartial(bucket, object, fi.VersionID)
    			break
    		}
    	}
    
    	for i := 0; i < len(onlineDisks); i++ {
    		if onlineDisks[i] != nil && onlineDisks[i].IsOnline() {
    			// Object info is the same in all disks, so we can pick
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  3. cmd/erasure.go

    }
    
    func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) {
    	onlineDisks = make(madmin.BackendDisks)
    	offlineDisks = make(madmin.BackendDisks)
    
    	for _, disk := range disksInfo {
    		ep := disk.Endpoint
    		if _, ok := offlineDisks[ep]; !ok {
    			offlineDisks[ep] = 0
    		}
    		if _, ok := onlineDisks[ep]; !ok {
    			onlineDisks[ep] = 0
    		}
    	}
    
    	// Wait for the routines.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  4. cmd/metacache-set.go

    				time.Sleep(retryDelay)
    			} else {
    				time.Sleep(retryDelay250)
    			}
    		}
    		// Load first part metadata...
    		// Read metadata associated with the object from all disks.
    		fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, minioMetaBucket, o.objectPath(0), ObjectOptions{}, true)
    		if err != nil {
    			switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) {
    			case ObjectNotFound, InsufficientReadQuorum:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    	}
    
    	result.ParityBlocks = result.DiskCount - readQuorum
    	result.DataBlocks = readQuorum
    
    	// List of disks having latest version of the object xl.meta
    	// (by modtime).
    	onlineDisks, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, readQuorum)
    
    	// Latest FileInfo for reference. If a valid metadata is not
    	// present, it is as good as object not found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    		var allDisks []madmin.Disk
    		for _, s := range servers {
    			allDisks = append(allDisks, s.Disks...)
    		}
    		onlineDisks, offlineDisks := getOnlineOfflineDisksStats(allDisks)
    
    		backend = madmin.ErasureBackend{
    			Type:             madmin.ErasureType,
    			OnlineDisks:      onlineDisks.Sum(),
    			OfflineDisks:     offlineDisks.Sum(),
    			StandardSCParity: backendInfo.StandardSCParity,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top