- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for MapOf (0.09 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
tlsVersion = TlsVersion.TLS_1_3, cipherSuite = CipherSuite.TLS_AES_128_GCM_SHA256, peerCertificates = listOf(), localCertificates = listOf(), ) return mapOf( Boolean::class.java to false, Call::class.java to FailingCall(), Connection::class.java to factory.newConnection(pool, route), Dispatcher::class.java to Dispatcher(),Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 70.5K bytes - Viewed (0) -
cmd/erasure-healing.go
return nil } // listAllBuckets lists all buckets from all disks. It also // returns the occurrence of each buckets in all disks func listAllBuckets(ctx context.Context, storageDisks []StorageAPI, healBuckets *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
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.7K bytes - Viewed (0) -
cmd/erasure-sets.go
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
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/erasure-server-pool.go
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.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 89.2K bytes - Viewed (0) -
cmd/site-replication.go
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),Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 184.8K bytes - Viewed (1) -
api/go1.1.txt
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
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Mar 31 20:37:15 UTC 2022 - 2.6M bytes - Viewed (0)