- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Refreshed (0.14 sec)
-
internal/dsync/drwmutex.go
ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.RefreshCall) defer cancel() refreshed, err := c.Refresh(ctx, args) if err != nil { ch <- refreshResult{offline: true} log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c) } else { ch <- refreshResult{refreshed: refreshed} log("dsync: Refresh returned false for %#v at %s\n", args, c) } }(index, c) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/internal/trace/reader.go
return ok, err } // Refresh the cursor's event. ok, err := bc.nextEvent(r.gen.batches[bc.m], r.gen.freq) if err != nil { return false, err } if ok { // If we successfully refreshed, update the heap. heapUpdate(r.frontier, i) } else { // There's nothing else to read. Delete this cursor from the frontier. r.frontier = heapRemove(r.frontier, i) } return true, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/api/apidiscovery/v2/types.go
// freshness marks whether a group version's discovery document is up to date. // "Current" indicates the discovery document was recently // refreshed. "Stale" indicates the discovery document could not // be retrieved and the returned discovery document may be // significantly out of date. Clients that require the latest
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
} mclaims := jwtgo.MapClaims(claims) jwtToken, err := jp.ParseWithClaims(token, &mclaims, keyFuncCallback) if err != nil { // Re-populate the public key in-case the JWKS // pubkeys are refreshed if err = r.PopulatePublicKey(arn); err != nil { return err } jwtToken, err = jwtgo.ParseWithClaims(token, &mclaims, keyFuncCallback) if err != nil { return err } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 18:10:41 UTC 2024 - 8.3K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/StartParameter.java
this.offline = offline; } /** * Specifies whether the dependencies should be refreshed.. */ public boolean isRefreshDependencies() { return refreshDependencies; } /** * Specifies whether the dependencies should be refreshed.. */ public void setRefreshDependencies(boolean refreshDependencies) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 06:24:50 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
ReadOnly: true, Managed: true, SELinuxRelabel: true, } } // SetUp puts in place the volume plugin. // This function is not idempotent by design. We want the data to be refreshed periodically. // The internal sync interval of kubelet will drive the refresh of data. // TODO: Add volume specific ticker and refresh loop func (b *downwardAPIVolumeMounter) SetUp(mounterArgs volume.MounterArgs) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
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) -
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) -
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) -
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)