return s.sets[s.getHashedSetIndex(input)]
}

// listDeletedBuckets lists deleted buckets from all disks.
func listDeletedBuckets(ctx context.Context, storageDisks []StorageAPI, delBuckets *xsync.MapOf[string, VolInfo], readQuorum int) error {
	g := errgroup.WithNErrs(len(storageDisks))
	for index := range storageDisks {
		g.Go(func() error {
			if storageDisks[index] == nil {
				// we ignore disk not found errors

	deploymentID     [16]byte
	distributionAlgo string

	serverPools []*erasureSets

	// Active decommission canceler
	decommissionCancelers []context.CancelFunc

	s3Peer *S3PeerSys

	mpCache *xsync.MapOf[string, MultipartInfo]
}

func (z *erasureServerPools) SinglePool() bool {
	return len(z.serverPools) == 1
}

// Initialize new pool of erasure sets.

			if svcErr != nil {
				return info, errSRBackendIssue(svcErr)
			}
		}
		info.UserPolicies = make(map[string]madmin.SRPolicyMapping, userPolicyMap.Size())
		addPolicy := func(t IAMUserType, mp *xsync.MapOf[string, MappedPolicy]) {
			mp.Range(func(k string, mp MappedPolicy) bool {
				info.UserPolicies[k] = madmin.SRPolicyMapping{
					IsGroup:     false,
					UserOrGroup: k,
					UserType:    int(t),

pkg reflect, const Uintptr = 12
pkg reflect, const UnsafePointer = 26
pkg reflect, func ChanOf(ChanDir, Type) Type
pkg reflect, func MakeFunc(Type, func([]Value) []Value) Value
pkg reflect, func MapOf(Type, Type) Type
pkg reflect, func Select([]SelectCase) (int, Value, bool)
pkg reflect, func SliceOf(Type) Type
pkg reflect, method (Value) Convert(Type) Value
pkg reflect, type SelectCase struct