- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 115 for continueCh (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
consistentReadFromStorage := resourceVersion == "" && !(consistentListFromCacheEnabled && requestWatchProgressSupported) // Watch cache doesn't support continuations, so serve them from etcd. hasContinuation := len(pred.Continue) > 0 // Serve paginated requests about revision "0" from watch cache to avoid overwhelming etcd. hasLimit := pred.Limit > 0 && resourceVersion != "0" // Watch cache only supports ResourceVersionMatchNotOlderThan (default).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
src/reflect/type.go
result.Index = append(result.Index, i) ok = true continue } // Queue embedded struct fields for processing with next level, // but only if we haven't seen a match yet at this level and only // if the embedded types haven't already been queued. if ok || ntyp == nil || ntyp.Kind() != abi.Struct { continue } styp := (*structType)(unsafe.Pointer(ntyp))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 85.5K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
"captured-waypoint", }) }) t.NewSubTest("before").Run(func(t framework.TestContext) { dst := apps.Captured for _, src := range apps.All { if src.Config().IsUncaptured() { continue } t.NewSubTestf("from %v", src.Config().Service).Run(func(t framework.TestContext) { c := IsL4() if src.Config().HasSidecar() { c = IsL7() } opt := echo.CallOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java
for (Profile profile : model.getProfiles()) { Activation activation = profile.getActivation(); if (activation == null) { continue; } if (clone) { activation = activation.clone(); } activations.put(profile.getId(), activation); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue May 21 09:54:32 UTC 2024 - 82.9K bytes - Viewed (0) -
src/time/format.go
c := s[i] if c < '0' || c > '9' { break } if overflow { continue } if x > (1<<63-1)/10 { // It's possible for overflow to give a positive number, so take care. overflow = true continue } y := x*10 + uint64(c) - '0' if y > 1<<63 { overflow = true continue } x = y scale *= 10 } return x, scale, s[i:] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:09:28 UTC 2024 - 49.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
pred.next = succ; if (pred.thread == null) { // We raced with another node that unlinked pred. Restart. continue restart; } } else if (!ATOMIC_HELPER.casWaiters(this, curr, succ)) { // We are unlinking head continue restart; // We raced with an add or complete } curr = succ; } break; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
pred.next = succ; if (pred.thread == null) { // We raced with another node that unlinked pred. Restart. continue restart; } } else if (!ATOMIC_HELPER.casWaiters(this, curr, succ)) { // We are unlinking head continue restart; // We raced with an add or complete } curr = succ; } break; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc
const llvm::SmallSet<int, 4> &resized_tensor_lists) { int func_index = 0; for (func::FuncOp func : {op.cond_function(), op.body_function()}) { ++func_index; if (!func) continue; FunctionType func_type = func.getFunctionType(); int num_inputs = func_type.getNumInputs(); int num_results = func_type.getNumResults();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 70.7K bytes - Viewed (0) -
src/net/http/request.go
// disk in temporary files. // ParseMultipartForm calls [Request.ParseForm] if necessary. // If ParseForm returns an error, ParseMultipartForm returns it but also // continues parsing the request body. // After one call to ParseMultipartForm, subsequent calls have no effect. func (r *Request) ParseMultipartForm(maxMemory int64) error { if r.MultipartForm == multipartByReader {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
tensorflow/BUILD
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 16:51:59 UTC 2024 - 53.5K bytes - Viewed (0)