- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 155 for continueCh (0.33 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) -
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) -
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 49.4K 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) -
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
// For functions, if the resource is used as a return operand, use that // as its result index. if (is_func && isa<func::ReturnOp>(user)) { assert(!info.IsResultIndexAssigned() && "Expect resource argument to returned no more than once"); info.result_index = use.getOperandNumber(); continue; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0)