Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 1,374 for Cake (0.02 seconds)

  1. cmd/erasure-decode_test.go

    	}
    
    	writers := make([]io.Writer, len(disks))
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    	content := make([]byte, size)
    	buffer := make([]byte, blockSizeV2, 2*blockSizeV2)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21K bytes
    - Click Count (0)
  2. cmd/peer-rest-client.go

    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    	hosts := endpoints.hostsSorted()
    	remote = make([]*peerRESTClient, 0, len(hosts))
    	all = make([]*peerRESTClient, len(hosts))
    	for i, host := range hosts {
    		if host == nil {
    			continue
    		}
    		all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Make 9 disks offline, which leaves less than quorum number of disks
    	// in a 16 disk Erasure setup. The original disks are 'replaced' with
    	// naughtyDisks that fail after 'f' successful StorageAPI method
    	// invocations, where f - [0,4)
    	for f := range 2 {
    		diskErrors := make(map[int]error)
    		for i := 0; i <= f; i++ {
    			diskErrors[i] = nil
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  4. cmd/bucket-replication-stats.go

    func (r *ReplicationStats) Get(bucket string) BucketReplicationStats {
    	if r == nil {
    		return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)}
    	}
    
    	r.RLock()
    	defer r.RUnlock()
    
    	st, ok := r.Cache[bucket]
    	if !ok {
    		return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)}
    	}
    	return st.Clone()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  5. cmd/bucket-stats.go

    	// read lock before calling Clone()
    
    	c = brs
    	// We need to copy the map, so we do not reference the one in `brs`.
    	c.Stats = make(map[string]*BucketReplicationStat, len(brs.Stats))
    	for arn, st := range brs.Stats {
    		// make a copy of `*st`
    		s := BucketReplicationStat{
    			ReplicatedSize:                   st.ReplicatedSize,
    			ReplicaSize:                      st.ReplicaSize,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  6. callbacks/associations.go

    								}
    							}
    						}
    					}
    				}
    
    				switch db.Statement.ReflectValue.Kind() {
    				case reflect.Slice, reflect.Array:
    					var (
    						rValLen   = db.Statement.ReflectValue.Len()
    						objs      = make([]reflect.Value, 0, rValLen)
    						fieldType = rel.Field.FieldType
    						isPtr     = fieldType.Kind() == reflect.Ptr
    					)
    
    					if !isPtr {
    						fieldType = reflect.PointerTo(fieldType)
    					}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Feb 13 06:16:26 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  7. internal/event/rulesmap.go

    	rules := make(Rules)
    	rules.Add(pattern, targetID)
    
    	for _, eventName := range eventNames {
    		for _, name := range eventName.Expand() {
    			rulesMap[name] = rulesMap[name].Union(rules)
    		}
    	}
    }
    
    // Clone - returns copy of this rules map.
    func (rulesMap RulesMap) Clone() RulesMap {
    	rulesMapCopy := make(RulesMap)
    
    	for eventName, rules := range rulesMap {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.6K bytes
    - Click Count (0)
  8. cmd/data-usage.go

    		dataUsageInfo.BucketsUsage = make(map[string]BucketUsageInfo, len(dataUsageInfo.BucketSizes))
    		for bucket, size := range dataUsageInfo.BucketSizes {
    			dataUsageInfo.BucketsUsage[bucket] = BucketUsageInfo{Size: size}
    		}
    	}
    
    	// For backward compatibility reasons, we need to add this code.
    	if len(dataUsageInfo.BucketSizes) == 0 {
    		dataUsageInfo.BucketSizes = make(map[string]uint64, len(dataUsageInfo.BucketsUsage))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu May 09 00:51:34 GMT 2024
    - 5.6K bytes
    - Click Count (0)
  9. cmd/erasure_test.go

    }
    
    func TestErasureEncodeDecode(t *testing.T) {
    	data := make([]byte, 256)
    	if _, err := io.ReadFull(rand.Reader, data); err != nil {
    		t.Fatalf("Failed to read random data: %v", err)
    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. cmd/admin-handlers-idp-openid.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, err), r.URL)
    		return
    	}
    
    	s := globalServerConfig.Clone()
    	roleArnMap := make(map[string]string)
    	// Map of configs to a map of users to their access keys
    	cfgToUsersMap := make(map[string]map[string]madmin.OpenIDUserAccessKeys)
    	configs, err := globalIAMSys.OpenIDConfig.GetConfigList(s)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 06 17:38:46 GMT 2025
    - 7.6K bytes
    - Click Count (0)
Back to Top