- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 96 for regressed (0.42 sec)
-
src/net/net.go
// fail instead of blocking. The deadline applies to all future // and pending I/O, not just the immediately following call to // Read or Write. After a deadline has been exceeded, the // connection can be refreshed by setting a deadline in the future. // // If the deadline is exceeded a call to Read or Write or to other // I/O methods will return an error that wraps os.ErrDeadlineExceeded.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/parser.go
// already progressed, no need to advance } c.Dir = RecvOnly t = c.Elem } if dir == SendOnly { // channel dir is <- but channel element E is not a channel // (report same error as for "type _ <-chan<-E") p.syntaxError(fmt.Sprintf("unexpected %s, expected chan", String(t))) // already progressed, no need to advance } return x }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 62.9K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
// GetConfig returns a specific configuration from the bucket metadata. // The returned object may not be modified. // reloaded will be true if metadata refreshed from disk func (sys *BucketMetadataSys) GetConfig(ctx context.Context, bucket string) (meta BucketMetadata, reloaded bool, err error) { objAPI := newObjectLayerFn() if objAPI == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/CachingModuleComponentRepository.java
if (cachePolicy.moduleExpiry(moduleComponentIdentifier, cachedMetadata.getModuleVersion(), cachedMetadata.getAge()).isMustCheck()) { LOGGER.debug("Cached meta-data for module must be refreshed: will perform fresh resolve of '{}' in '{}'", moduleComponentIdentifier, delegate.getName()); return; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 28.3K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
close(e.stopCacheUpdateCh) } // In case the Evented PLEG experiences undetectable issues in the underlying // GRPC connection there is a remote chance the pod might get stuck in a // given state while it has progressed in its life cycle. This function will be // called periodically to update the global timestamp of the cache so that those // pods stuck at GetNewerThan in pod workers will get unstuck. func (e *EventedPLEG) updateGlobalCache() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} return nil } } // MetricsGroup - represents a group of metrics. It includes a `MetricsLoaderFn` // function that provides a way to load the metrics from the system. The metrics // are cached and refreshed after a given timeout. // // For metrics with a `bucket` dimension, a list of buckets argument is required // to collect the metrics. // // It implements the prometheus.Collector interface for metric groups without a
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 15.1K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver_test.go
} r.refresh() } // Verify refresh job key changed count is zero. if got, want := r.refreshJobKeyChangedCount, uint64(0); got != want { t.Errorf("JWKs Resolver Refreshed Key Count => expected %d but got %d", want, got) } } func TestGetPublicKeyUsingTLS(t *testing.T) { r := newJwksResolverWithCABundlePaths( JwtPubKeyEvictionDuration, JwtPubKeyRefreshInterval,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
if err != nil { return "", err } } } } // Create new podToMount object. If it already exists, it is refreshed with // updated values (this is required for volumes that require remounting on // pod update, like Downward API volumes). dsw.volumesToMount[volumeName].podsToMount[podName] = podToMount{ podName: podName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/istio-agent/agent.go
if err != nil { return fmt.Errorf("failed to start workload secret manager %v", err) } if a.cfg.DisableEnvoy { // For proxyless we don't need an SDS server, but still need the keys and // we need them refreshed periodically. // // This is based on the code from newSDSService, but customized to have explicit rotation. go func() { st := a.secretCache st.RegisterSecretHandler(func(resourceName string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
return ControllerContext{}, fmt.Errorf("failed to wait for apiserver being healthy: %v", err) } // Use a discovery client capable of being refreshed. discoveryClient := rootClientBuilder.DiscoveryClientOrDie("controller-discovery") cachedClient := cacheddiscovery.NewMemCacheClient(discoveryClient) restMapper := restmapper.NewDeferredDiscoveryRESTMapper(cachedClient)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0)