Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for minDisks (0.11 sec)

  1. cmd/metacache-set.go

    			agree = 1
    			current = entry
    			topEntries[i] = entry
    		}
    
    		// Since minDisks is set to quorum, we return if we have enough.
    		if vnf > 0 && vnf >= len(readers)-opts.minDisks {
    			return errVolumeNotFound
    		}
    		// Since minDisks is set to quorum, we return if we have enough.
    		if fnf > 0 && fnf >= len(readers)-opts.minDisks {
    			return errFileNotFound
    		}
    
    		// Stop if we exceed number of bad disks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K 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)
Back to top