From 8cb5234417ce3043eedd36e5f5959fc67300d35e Mon Sep 17 00:00:00 2001 From: Ben Manes Date: Wed, 15 Jan 2025 16:31:43 -0800 Subject: [PATCH] wip --- .../caffeine/cache/BoundedLocalCache.java | 16 ++++++---------- .../gradle/libs.versions.toml | 2 +- gradle/libs.versions.toml | 2 +- 3 files changed, 8 insertions(+), 12 deletions(-) diff --git a/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java b/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java index e4c07c5458..cd006dda5a 100644 --- a/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java +++ b/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java @@ -2298,8 +2298,8 @@ public void putAll(Map map) { if (node == null) { node = nodeFactory.newNode(key, keyReferenceQueue(), value, valueReferenceQueue(), newWeight, now); - setVariableTime(node, expireAfterCreate(key, value, expiry, now)); long expirationTime = isComputingAsync(value) ? (now + ASYNC_EXPIRY) : now; + setVariableTime(node, expireAfterCreate(key, value, expiry, now)); setAccessTime(node, expirationTime); setWriteTime(node, expirationTime); } @@ -2688,8 +2688,8 @@ public void replaceAll(BiFunction function) { weight[1] = weigher.weigh(key, newValue[0]); var created = nodeFactory.newNode(key, keyReferenceQueue(), newValue[0], valueReferenceQueue(), weight[1], now[0]); - setVariableTime(created, expireAfterCreate(key, newValue[0], expiry(), now[0])); long expirationTime = isComputingAsync(newValue[0]) ? (now[0] + ASYNC_EXPIRY) : now[0]; + setVariableTime(created, expireAfterCreate(key, newValue[0], expiry(), now[0])); setAccessTime(created, expirationTime); setWriteTime(created, expirationTime); return created; @@ -2724,15 +2724,11 @@ public void replaceAll(BiFunction function) { n.setValue(newValue[0], valueReferenceQueue()); n.setWeight(weight[1]); + long expirationTime = isComputingAsync(newValue[0]) ? (now[0] + ASYNC_EXPIRY) : now[0]; + setAccessTime(n, expirationTime); + setWriteTime(n, expirationTime); setVariableTime(n, varTime); - if (isComputingAsync(newValue[0])) { - long expirationTime = now[0] + ASYNC_EXPIRY; - setAccessTime(n, expirationTime); - setWriteTime(n, expirationTime); - } else { - setAccessTime(n, now[0]); - setWriteTime(n, now[0]); - } + discardRefresh(k); return n; } diff --git a/examples/coalescing-bulkloader-reactor/gradle/libs.versions.toml b/examples/coalescing-bulkloader-reactor/gradle/libs.versions.toml index 5415fed147..299c2ec435 100644 --- a/examples/coalescing-bulkloader-reactor/gradle/libs.versions.toml +++ b/examples/coalescing-bulkloader-reactor/gradle/libs.versions.toml @@ -1,7 +1,7 @@ [versions] caffeine = "3.1.8" junit = "5.11.4" -reactor = "3.7.1" +reactor = "3.7.2" truth = "1.4.4" versions = "0.51.0" diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 74837298ce..b32476ebd4 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -4,7 +4,7 @@ auto-value = "1.11.0" awaitility = "4.2.2" bcel = "6.10.0" bnd = "7.1.0" -bouncycastle-jdk18on = "1.79" +bouncycastle-jdk18on = "1.80" cache2k = "2.6.1.Final" caffeine = "3.1.8" checkstyle = "10.21.1"