- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for bucketPop (0.31 sec)
-
cmd/erasure-server-pool-decom.go
BytesDone: pd.BytesDone, BytesFailed: pd.BytesFailed, } } // bucketPop should be called when a bucket is done decommissioning. // Adds the bucket to the list of decommissioned buckets and updates resume numbers. func (pd *PoolDecommissionInfo) bucketPop(bucket string) bool { pd.DecommissionedBuckets = append(pd.DecommissionedBuckets, bucket) for i, b := range pd.QueuedBuckets {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1) -
cmd/admin-bucket-handlers.go
rpt.SetStatus(bucket, fileName, err) continue } v, _ := globalBucketMetadataSys.Get(bucket) bucketMap[bucket] = &v } bucketMap[bucket].ObjectLockConfigXML = configData bucketMap[bucket].ObjectLockConfigUpdatedAt = updatedAt rpt.SetStatus(bucket, fileName, nil) } } // import versioning metadata for _, file := range zr.File { slc := strings.Split(file.Name, slashSeparator)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 32.7K bytes - Viewed (0) -
src/runtime/map_fast64.go
var insertb *bmap var inserti uintptr var insertk unsafe.Pointer bucketloop: for { for i := uintptr(0); i < abi.MapBucketCount; i++ { if isEmpty(b.tophash[i]) { if insertb == nil { insertb = b inserti = i } if b.tophash[i] == emptyRest { break bucketloop } continue } k := *((*uint64)(add(unsafe.Pointer(b), dataOffset+i*8)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:17:26 UTC 2024 - 14.1K bytes - Viewed (0) -
src/runtime/map_fast32.go
var insertb *bmap var inserti uintptr var insertk unsafe.Pointer bucketloop: for { for i := uintptr(0); i < abi.MapBucketCount; i++ { if isEmpty(b.tophash[i]) { if insertb == nil { inserti = i insertb = b } if b.tophash[i] == emptyRest { break bucketloop } continue } k := *((*uint32)(add(unsafe.Pointer(b), dataOffset+i*4)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:17:26 UTC 2024 - 13.9K bytes - Viewed (0) -
src/reflect/export_test.go
r = append(r, typ.String()) } } return r } var GCBits = gcbits func gcbits(any) []byte // provided by runtime func MapBucketOf(x, y Type) Type { return toType(bucketOf(x.common(), y.common())) } func CachedBucketOf(m Type) Type { t := m.(*rtype) if Kind(t.t.Kind_&abi.KindMask) != Map { panic("not map") } tt := (*mapType)(unsafe.Pointer(t))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 15:10:48 UTC 2024 - 3.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MapsTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 15:27:58 UTC 2024 - 67.1K bytes - Viewed (0) -
src/runtime/map.go
if !evacuated(oldb) { b = oldb } } top := tophash(hash) bucketloop: for ; b != nil; b = b.overflow(t) { for i := uintptr(0); i < abi.MapBucketCount; i++ { if b.tophash[i] != top { if b.tophash[i] == emptyRest { break bucketloop } continue } k := add(unsafe.Pointer(b), dataOffset+i*uintptr(t.KeySize)) if t.IndirectKey() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 57.6K bytes - Viewed (0) -
src/runtime/map_faststr.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:17:26 UTC 2024 - 15.3K bytes - Viewed (0) -
src/reflect/type.go
mt.TFlag = 0 mt.Hash = fnv1(etyp.Hash, 'm', byte(ktyp.Hash>>24), byte(ktyp.Hash>>16), byte(ktyp.Hash>>8), byte(ktyp.Hash)) mt.Key = ktyp mt.Elem = etyp mt.Bucket = bucketOf(ktyp, etyp) mt.Hasher = func(p unsafe.Pointer, seed uintptr) uintptr { return typehash(ktyp, p, seed) } mt.Flags = 0 if ktyp.Size_ > abi.MapMaxKeyBytes { mt.KeySize = uint8(goarch.PtrSize)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 85.5K bytes - Viewed (0)