Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for bucketPop (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. guava-tests/test/com/google/common/collect/MapsTest.java

        // deal with empty-map optimization.
        map1.put(0, null);
    
        int initialBuckets = bucketsOf(map1);
    
        for (int i = 1; i < size; i++) {
          map1.put(i, null);
        }
        assertWithMessage("table size after adding " + size + " elements")
            .that(bucketsOf(map1))
            .isEqualTo(initialBuckets);
    
        /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 15:27:58 UTC 2024
    - 67.1K bytes
    - Viewed (0)
  7. 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)
  8. src/runtime/map_faststr.go

    	var insertb *bmap
    	var inserti uintptr
    	var insertk unsafe.Pointer
    
    bucketloop:
    	for {
    		for i := uintptr(0); i < abi.MapBucketCount; i++ {
    			if b.tophash[i] != top {
    				if isEmpty(b.tophash[i]) && insertb == nil {
    					insertb = b
    					inserti = i
    				}
    				if b.tophash[i] == emptyRest {
    					break bucketloop
    				}
    				continue
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  9. 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)
Back to top