Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for portCount (1.97 sec)

  1. pkg/proxy/servicechangetracker.go

    	if reflect.DeepEqual(change.previous, change.current) {
    		delete(sct.items, namespacedName)
    	} else {
    		klog.V(4).InfoS("Service updated ports", "service", klog.KObj(svc), "portCount", len(change.current))
    	}
    	metrics.ServiceChangesPending.Set(float64(len(sct.items)))
    	return len(sct.items) > 0
    }
    
    // ServicePortMap maps a service to its ServicePort.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/MultipartReader.kt

              0 -> {
                // "\r\n": We've found a new part.
                partCount++
                break@afterBoundaryLoop
              }
    
              1 -> {
                // "--": No more parts.
                if (whitespace) throw ProtocolException("unexpected characters after boundary")
                if (partCount == 0) throw ProtocolException("expected at least 1 part")
                noMoreParts = true
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    	}
    	setObjectLayer(obj)
    	defer obj.Shutdown(context.Background())
    	defer removeRoots(disks)
    
    	bucket := "bucket"
    	object := "object"
    	// make data with more than one part
    	partCount := 3
    	data := bytes.Repeat([]byte("a"), 6*1024*1024*partCount)
    	z := obj.(*erasureServerPools)
    	s := z.serverPools[0].sets[0]
    	erasureDisks := s.getDisks()
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  4. cmd/erasure-object_test.go

    	bucket := getRandomBucketName()
    
    	var opts ObjectOptions
    	// make data with more than one part
    	partCount := 3
    	data := bytes.Repeat([]byte("a"), 6*1024*1024*partCount)
    
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top