- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for BREAK (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)