- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for NOW (0.13 sec)
-
android/guava/src/com/google/common/cache/LocalCache.java
ReferenceEntry<K, V> e = getEntry(key, hash); if (e != null) { long now = map.ticker.read(); V value = getLiveValue(e, now); if (value != null) { recordRead(e, now); statsCounter.recordHits(1); return scheduleRefresh(e, key, hash, value, now, loader); } ValueReference<K, V> valueReference = e.getValueReference();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.30.md
- Promoted `AdmissionWebhookMatchConditions` to GA. The feature is now stable, and the feature gate is now locked to default. ([#123560](https://github.com/kubernetes/kubernetes/pull/123560), [@ivelichkovich](https://github.com/ivelichkovich))
Plain Text - Registered: Fri May 03 09:05:14 GMT 2024 - Last Modified: Wed Apr 17 17:56:15 GMT 2024 - 227.9K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
ReferenceEntry<K, V> e = getEntry(key, hash); if (e != null) { long now = map.ticker.read(); V value = getLiveValue(e, now); if (value != null) { recordRead(e, now); statsCounter.recordHits(1); return scheduleRefresh(e, key, hash, value, now, loader); } ValueReference<K, V> valueReference = e.getValueReference();
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
cmd/site-replication.go
Type: madmin.SRBucketMetaLCConfig, Bucket: bucket, ExpiryLCConfig: &configStr, UpdatedAt: time.Now(), }) if err != nil { return errSRBucketMetaError(err) } } } } // Order matters from now on how the information is // synced to remote sites. // Policies should be synced first. {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/admin-handlers.go
// - freeze (freezes all incoming S3 API calls) // - unfreeze (unfreezes previously frozen S3 API calls) // // This newer API now returns back status per remote peer and local regarding // if a "restart/stop" was successful or not. Service signal now supports // a dry-run that helps skip the nodes that may have hung drives. By default // restart/stop will ignore the servers that are hung on drives. You can use
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/bucket-replication.go
// The source object is then updated to reflect the replication status. func (ri ReplicateObjectInfo) replicateObject(ctx context.Context, objectAPI ObjectLayer, tgt *TargetClient) (rinfo replicatedTargetInfo) { startTime := time.Now() bucket := ri.Bucket object := ri.Name rAction := replicateAll rinfo = replicatedTargetInfo{ Size: ri.ActualSize, Arn: tgt.ARN,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/Maps.java
* * <p><b>Note:</b> if {@code K} is an {@code enum} type, use {@link #newEnumMap} instead. * * <p><b>Note:</b> this method is now unnecessary and should be treated as deprecated. Instead, * use the {@code HashMap} constructor directly, taking advantage of <a * href="http://goo.gl/iz2Wi">"diamond" syntax</a>. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 159.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
f1.cancel(true); assertTrue(f2.isCancelled()); /* * We might like to propagate interruption, too, but it's not clear that it matters. For now, we * test for the behavior that we have today. */ assertFalse(((AbstractFuture<?>) f2).wasInterrupted()); } /*
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
f1.cancel(true); assertTrue(f2.isCancelled()); /* * We might like to propagate interruption, too, but it's not clear that it matters. For now, we * test for the behavior that we have today. */ assertFalse(((AbstractFuture<?>) f2).wasInterrupted()); } /*
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
private static <K, V> int countLiveEntries(LocalCache<K, V> map, long now) { int result = 0; for (Segment<K, V> segment : map.segments) { AtomicReferenceArray<ReferenceEntry<K, V>> table = segment.table; for (int i = 0; i < table.length(); i++) { for (ReferenceEntry<K, V> e = table.get(i); e != null; e = e.getNext()) { if (map.isLive(e, now)) { result++; } }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0)