Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,357 for makeT (0.03 sec)

  1. 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)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. internal/config/lambda/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	keys := make([]ARN, 0, len(list.targets))
    	for k := range list.targets {
    		keys = append(keys, k.ToARN(region))
    	}
    
    	return keys
    }
    
    // TargetMap - returns available targets.
    func (list *TargetList) TargetMap() map[TargetID]Target {
    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

            }
          }
    
        // Make the first request waiting until we get our auth challenge.
        val request = Request(server.url("/"))
        blockingAuthClient.newCall(request).enqueue(callback)
        val response1 = responses.take()
        assertThat(response1).isEqualTo("")
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
  4. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Sep 06 17:38:46 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  5. 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))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common_test.go

    		deletePart
    		corruptPart
    	)
    
    	timeSentinel := time.Unix(1, 0).UTC()
    	threeNanoSecs := time.Unix(3, 0).UTC()
    	fourNanoSecs := time.Unix(4, 0).UTC()
    	modTimesThreeNone := make([]time.Time, 16)
    	modTimesThreeFour := make([]time.Time, 16)
    	for i := range 16 {
    		// Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one
    		// to be tampered with.
    		if i > 12 {
    			modTimesThreeFour[i] = fourNanoSecs
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  7. 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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  8. 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)
    					}
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Feb 13 06:16:26 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  9. 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
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  10. cmd/admin-server-info.go

    	addr := globalLocalNodeName
    	if r != nil {
    		addr = r.Host
    	}
    	if globalIsDistErasure {
    		addr = globalLocalNodeName
    	}
    	poolNumbers := make(map[int]struct{})
    	network := make(map[string]string)
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				poolNumbers[endpoint.PoolIdx+1] = struct{}{}
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (1)
Back to top