- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 297 for continueCh (0.14 sec)
-
src/net/http/transport.go
continueCh := rc.continueCh for { resp, err = ReadResponse(pc.br, rc.treq.Request) if err != nil { return } resCode := resp.StatusCode if continueCh != nil && resCode == StatusContinue { if trace != nil && trace.Got100Continue != nil { trace.Got100Continue() } continueCh <- struct{}{} continueCh = nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
{ name: "test List with pregenerated continue token", prefix: "/pods/second/", pred: storage.SelectionPredicate{ Label: labels.Everything(), Field: fields.Everything(), Limit: 1, Continue: secondContinuation, }, expectedOut: []example.Pod{*preset[2]}, }, { name: "ignores resource version 0 for List with pregenerated continue token", prefix: "/pods/second/",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
src/regexp/testdata/testregex.c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 51.3K bytes - Viewed (0) -
cmd/erasure-object.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/regalloc.go
for _, live := range s.live[b.ID] { if live.dist >= unlikelyDistance { // Don't preload anything live after the loop. continue } vid := live.ID vi := &s.values[vid] if vi.regs != 0 { continue } if vi.rematerializeable { continue } v := s.orig[vid] m := s.compatRegs(v.Type) &^ s.used // Used desired register if available.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:49:56 UTC 2023 - 87.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if disk == OfflineDisk { continue } stats, err := disk.StatInfoFile(ctx, volume, file, true) if err != nil { continue } for _, si := range stats { found++ var r io.ReadCloser if !si.Dir { r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size) if err != nil { continue } } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
pilot/pkg/model/virtualservice_test.go
*r = networking.HTTPRouteDestination{} }, func(r *networking.HTTPRedirect, c fuzz.Continue) { *r = networking.HTTPRedirect{} }, func(r *networking.HTTPDirectResponse, c fuzz.Continue) { *r = networking.HTTPDirectResponse{} }, func(r *networking.Delegate, c fuzz.Continue) { *r = networking.Delegate{} }, func(r *networking.HTTPRewrite, c fuzz.Continue) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 60.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
pg := f.pluginsMap[e.Name] if !reflect.TypeOf(pg).Implements(pluginType) { continue } // We append MultiPoint plugins to the list of Score plugins. So if this plugin has already been // encountered, let the individual Score weight take precedence. if _, ok := f.scorePluginWeight[e.Name]; ok { continue } // a weight of zero is not permitted, plugins can be disabled explicitly
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
for _, epInfo := range proxier.endpointsMap[svcName] { ep, ok := epInfo.(*endpointInfo) if !ok { continue } if isLocalTrafficDSR && !ep.IsLocal() { // KEP-1669: Ignore remote endpoints when the ExternalTrafficPolicy is Local (DSR Mode) continue } // If Readiness Probe fails and pod is not under delete, then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0)