Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for BREAK (0.06 sec)

  1. cmd/erasure-multipart.go

    			if uploads[uploadIndex].UploadID == uploadIDMarker {
    				uploadIndex++
    				break
    			}
    			uploadIndex++
    		}
    	}
    	for uploadIndex < len(uploads) {
    		result.Uploads = append(result.Uploads, uploads[uploadIndex])
    		result.NextUploadIDMarker = uploads[uploadIndex].UploadID
    		uploadIndex++
    		if len(result.Uploads) == maxUploads {
    			break
    		}
    	}
    
    	result.IsTruncated = uploadIndex < len(uploads)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster.go

    				continue
    			}
    			if hostIP == model.PodIPAddressPrefix {
    				for _, proxyIPAddr := range cb.proxyIPAddresses {
    					if netutil.IsIPv4Address(proxyIPAddr) {
    						endpointAddress = proxyIPAddr
    						break
    					}
    				}
    				// if there is no any IPv4 address in proxyIPAddresses
    				if endpointAddress == "" {
    					endpointAddress = model.LocalhostAddressPrefix
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_waypoint.go

    				// As an optimization, we can just stop sending any more routes here.
    				if istio_route.IsCatchAllRoute(r) {
    					catchall = true
    					break
    				}
    			}
    		}
    		if catchall {
    			break
    		}
    	}
    
    	if len(out) == 0 {
    		return nil, fmt.Errorf("no routes matched")
    	}
    	return out, nil
    }
    
    func (lb *ListenerBuilder) translateRoute(
    	virtualService config.Config,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    				continue
    			}
    			found = true
    			break
    		}
    		if found {
    			compareMeta1[strings.ToLower(k)] = v
    		}
    	}
    
    	compareMeta2 := make(map[string]string)
    	for k, v := range oi2.Metadata {
    		var found bool
    		for _, prefix := range compareKeys {
    			if !stringsHasPrefixFold(k, prefix) {
    				continue
    			}
    			found = true
    			break
    		}
    		if found {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    	)
    
    	maxParts := 1000
    	// Canonicalize the form values into http.Header.
    	formValues := make(http.Header)
    	for {
    		part, err := mp.NextRawPart()
    		if errors.Is(err, io.EOF) {
    			break
    		}
    		if err != nil {
    			apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest)
    			apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err)
    			writeErrorResponse(ctx, w, apiErr, r.URL)
    			return
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    			break
    		}
    		if len(containerStatus.AllocatedResources) != len(container.Resources.Requests) {
    			klog.V(5).InfoS("ContainerStatus.AllocatedResources length mismatch", "pod", pod.Name, "container", container.Name)
    			break
    		}
    		if !cmp.Equal(container.Resources.Requests, containerStatus.AllocatedResources) {
    			podResized = true
    			break
    		}
    	}
    	if !podResized {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  7. pilot/pkg/model/endpointshards.go

    		// removal so we need to push an update.
    		if !needPush {
    			for _, oie := range oldIstioEndpoints {
    				if _, f := nmap[oie.Address]; !f {
    					needPush = true
    					break
    				}
    			}
    		}
    	}
    
    	if pushType != FullPush && !needPush {
    		log.Debugf("No push, either old endpoint health status did not change or new endpoint came with unhealthy status, %v", hostname)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods.go

    		validSecondaryIP = utilnet.IsIPv4String
    	}
    	for _, ip := range podIPs {
    		if validPrimaryIP(ip) {
    			ips = append(ips, ip)
    			break
    		}
    	}
    	for _, ip := range podIPs {
    		if validSecondaryIP(ip) {
    			ips = append(ips, ip)
    			break
    		}
    	}
    	return ips
    }
    
    // convertStatusToAPIStatus initialize an api PodStatus for the given pod from
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    	// Locate the part containing the start of the required range
    	var partEnd int
    	var cumulativeSum, encCumulativeSum int64
    	for i, size := range sizes {
    		if off < cumulativeSum+size {
    			partStart = i
    			break
    		}
    		cumulativeSum += size
    		encPartSize, _ := sio.EncryptedSize(uint64(size))
    		encCumulativeSum += int64(encPartSize)
    	}
    	// partStart is always found in the loop above,
    	// because off is validated.
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  10. pilot/pkg/simulation/traffic.go

    ) []*listener.FilterChain {
    	res := []*listener.FilterChain{}
    	anySet := false
    	for _, c := range chains {
    		if !empty(c.GetFilterChainMatch()) {
    			anySet = true
    			break
    		}
    	}
    	if !anySet {
    		log.Debugf("%v: none set, skipping", desc)
    		return chains
    	}
    	for i, c := range chains {
    		if match(c.GetFilterChainMatch()) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top