Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for diskCount (0.08 sec)

  1. cmd/erasure-healing-common.go

    	timeSentinel1970 = time.Unix(0, 1).UTC() // 1970 used for special cases when xlmeta.version == 0
    )
    
    // Boot modTimes up to disk count, setting the value to time sentinel.
    func bootModtimes(diskCount int) []time.Time {
    	modTimes := make([]time.Time, diskCount)
    	// Boots up all the modtimes.
    	for i := range modTimes {
    		modTimes[i] = timeSentinel
    	}
    	return modTimes
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils.go

    }
    
    // Similar to 'len(slice)' but returns the actual elements count
    // skipping the unallocated elements.
    func diskCount(disks []StorageAPI) int {
    	diskCount := 0
    	for _, disk := range disks {
    		if disk == nil {
    			continue
    		}
    		diskCount++
    	}
    	return diskCount
    }
    
    // hashOrder - hashes input key to return consistent
    // hashed integer slice. Returned integer order is salted
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    		}()
    	}
    
    	// Initialize heal result object
    	result = madmin.HealResultItem{
    		Type:      madmin.HealItemObject,
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    		DiskCount: len(storageDisks),
    	}
    
    	if !opts.NoLock {
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return result, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. cmd/peer-s3-server.go

    				return serr
    			}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    		SetCount:  -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	// mutate only if not a dry-run
    	if opts.DryRun {
    		return res, nil
    	}
    
    	for i := range beforeState {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common_test.go

    					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:
    				for index, err := range test.errs {
    					if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    			continue
    		}
    		// Count errNoHealRequired across all serverPools,
    		// to return appropriate error to the caller
    		if errors.Is(err, errNoHealRequired) {
    			countNoHeal++
    		}
    		r.DiskCount += result.DiskCount
    		r.SetCount += result.SetCount
    		r.Before.Drives = append(r.Before.Drives, result.Before.Drives...)
    		r.After.Drives = append(r.After.Drives, result.After.Drives...)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  7. cmd/erasure-sets.go

    	if err != nil {
    		return res, err
    	}
    
    	// Prepare heal-result
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemMetadata,
    		Detail:    "disk-format",
    		DiskCount: s.setCount * s.setDriveCount,
    		SetCount:  s.setCount,
    	}
    
    	// Fetch all the drive info status.
    	beforeDrives := formatsToDrivesInfo(s.endpoints.Endpoints, formats, sErrs)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top