Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for minDisks (0.07 sec)

  1. cmd/erasure-object.go

    		return
    	}()
    
    	validResp := 0
    	totalResp := 0
    
    	// minDisks value is only to reduce the number of calls
    	// to the disks; this value is not accurate because we do
    	// not know the storage class of the object yet
    	minDisks := 0
    	if p := globalStorageClass.GetParityForSC(""); p > -1 {
    		minDisks = er.setDriveCount - p
    	} else {
    		minDisks = er.setDriveCount - er.defaultParityCount
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    		}
    
    		err = listPathRaw(ctx, listPathRawOptions{
    			disks:          disks,
    			fallbackDisks:  fallbackDisks,
    			bucket:         bucket,
    			recursive:      true,
    			forwardTo:      forwardTo,
    			minDisks:       1,
    			reportNotFound: false,
    			agreed: func(entry metaCacheEntry) {
    				jt.Take()
    				go healEntry(bucket, entry)
    			},
    			partial: func(entries metaCacheEntries, _ []error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    		bucket:    bucketName,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bucketName,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if ok {
    				fn(*entry)
    			}
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    		disks:          disks,
    		fallbackDisks:  fallbackDisks,
    		bucket:         bucket,
    		path:           path,
    		filterPrefix:   filterPrefix,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       1,
    		reportNotFound: false,
    		agreed: func(entry metaCacheEntry) {
    			if err := healEntry(bucket, entry, scanMode); err != nil {
    				cancel()
    			}
    		},
    		partial: func(entries metaCacheEntries, _ []error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom.go

    		bucket:    bi.Name,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bi.Name,
    		path:           bi.Prefix,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if ok {
    				fn(*entry)
    			}
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    			err := listPathRaw(ctx, listPathRawOptions{
    				disks:          f.disks,
    				bucket:         bucket,
    				path:           prefix,
    				recursive:      true,
    				reportNotFound: true,
    				minDisks:       f.disksQuorum,
    				agreed: func(entry metaCacheEntry) {
    					f.updateCurrentPath(entry.name)
    					if f.dataUsageScannerDebug {
    						console.Debugf(healObjectsPrefix+" got agreement: %v\n", entry.name)
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    					bucket:         bucket,
    					path:           path,
    					filterPrefix:   filterPrefix,
    					recursive:      true,
    					forwardTo:      opts.Marker,
    					perDiskLimit:   opts.Limit,
    					minDisks:       listingQuorum,
    					reportNotFound: false,
    					agreed:         send,
    					partial: func(entries metaCacheEntries, _ []error) {
    						entry, ok := entries.resolve(&resolver)
    						if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top