- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,834 for happen (0.24 sec)
-
src/net/http/servemux121.go
n := len(es) i := sort.Search(n, func(i int) bool { return len(es[i].pattern) < len(e.pattern) }) if i == n { return append(es, e) } // we now know that i points at where we want to insert es = append(es, muxEntry{}) // try to grow the slice in place, any entry works. copy(es[i+1:], es[i:]) // Move shorter entries down es[i] = e return es }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 15:40:38 UTC 2024 - 5.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/delete_test.go
"k8s.io/klog/v2/ktesting" pvtesting "k8s.io/kubernetes/pkg/controller/volume/persistentvolume/testing" "k8s.io/kubernetes/pkg/features" ) // Test single call to syncVolume, expecting recycling to happen. // 1. Fill in the controller with initial data // 2. Call the syncVolume *once*. // 3. Compare resulting volumes with expected volumes. func TestDeleteSync(t *testing.T) { const gceDriver = "pd.csi.storage.gke.io"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.8K bytes - Viewed (0) -
src/runtime/chan.go
// Instead of individual buffer entries, the race detector uses the // c.buf as the only buffer entry. This simplification prevents us from // following the memory model's happens-before rules (rules that are // implemented in racereleaseacquire). Instead, we accumulate happens-before // information in the synchronization object associated with c.buf. if c.elemsize == 0 { if sg == nil { raceacquire(qp) racerelease(qp)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/apis.go
} if len(apiGroupInfo.VersionedResourcesStorageMap) == 0 { // If we have no storage for any resource configured, this API group is effectively disabled. // This can happen when an entire API group, version, or development-stage (alpha, beta, GA) is disabled. klog.Infof("API group %q is not enabled, skipping.", groupName) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 6.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go
var endpoints []string for _, ev := range m.EndpointVersion { endpoints = append(endpoints, ev.Endpoint) } return endpoints } func (m MockEtcdClient) getVersion(endpoint string) (string, error) { for _, ev := range m.EndpointVersion { if ev.Endpoint == endpoint { return ev.Version, ev.Error } } // Never should happen, unless tests having a problem. return "", fmt.Errorf("No version found") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 8.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/initialize_variables_in_session_init.cc
auto* var_ptr = GetVariableFromSession(var_op, handle.device(), mgr); if (!var_ptr) { // If no value in session, then just skip this variable. // This can happen if the variable is not saved in checkpoint. // For example, when the variable is created on every call. continue; } tensorflow::core::RefCountPtr<tensorflow::Var> var(var_ptr);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 23 09:05:47 UTC 2024 - 7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultPackagingRegistry.java
public Optional<Packaging> lookup(String id) { id = id.toLowerCase(Locale.ROOT); // TODO: we should be able to inject a Map<String, LifecycleMapping> directly, // however, SISU visibility filtering can only happen when an explicit // lookup is performed. The whole problem here is caused by "project extensions" // which are bound to a project's classloader, without any clear definition // of a "project scope"
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed May 22 13:45:13 UTC 2024 - 8K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// The protobuf message which contains LbEndpoint slice. llbEndpoints endpoint.LocalityLbEndpoints } func (e *LocalityEndpoints) append(ep *model.IstioEndpoint, le *endpoint.LbEndpoint) { e.istioEndpoints = append(e.istioEndpoints, ep) e.llbEndpoints.LbEndpoints = append(e.llbEndpoints.LbEndpoints, le) } func (e *LocalityEndpoints) refreshWeight() { var weight *wrapperspb.UInt32Value
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/speedtest.go
Err: errStr, }) totalUploadTimes = append(totalUploadTimes, throughputHighestResults[i].UploadTimes...) totalDownloadTimes = append(totalDownloadTimes, throughputHighestResults[i].DownloadTimes...) totalDownloadTTFB = append(totalDownloadTTFB, throughputHighestResults[i].DownloadTTFB...) } result.PUTStats.Response = totalUploadTimes.Measure() result.GETStats.Response = totalDownloadTimes.Measure()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/metrics-v3-types.go
labels := make([]string, 0, len(metric.VariableLabels)*2) for k, v := range metric.VariableLabels { if newLabel, ok := renameLabels[k]; ok { labels = append(labels, newLabel, v) } else { labels = append(labels, k, v) } } labels = append(labels, extraLabels...) // If valid non zero value set the metrics if metric.Value > 0 { m.Set(name, metric.Value, labels...) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 15.1K bytes - Viewed (0)