You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@deltaspike.apache.org by st...@apache.org on 2016/04/29 11:20:24 UTC
deltaspike git commit: DELTASPIKE-1139 fix high-load concurrency issue
Repository: deltaspike
Updated Branches:
refs/heads/master 53e54564c -> 8e23c8205
DELTASPIKE-1139 fix high-load concurrency issue
Project: http://git-wip-us.apache.org/repos/asf/deltaspike/repo
Commit: http://git-wip-us.apache.org/repos/asf/deltaspike/commit/8e23c820
Tree: http://git-wip-us.apache.org/repos/asf/deltaspike/tree/8e23c820
Diff: http://git-wip-us.apache.org/repos/asf/deltaspike/diff/8e23c820
Branch: refs/heads/master
Commit: 8e23c8205d18d4a5b4567bce9e53b656010742b6
Parents: 53e5456
Author: Mark Struberg <st...@apache.org>
Authored: Fri Apr 29 11:15:47 2016 +0200
Committer: Mark Struberg <st...@apache.org>
Committed: Fri Apr 29 11:15:47 2016 +0200
----------------------------------------------------------------------
.../org/apache/deltaspike/core/api/config/ConfigResolver.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/deltaspike/blob/8e23c820/deltaspike/core/api/src/main/java/org/apache/deltaspike/core/api/config/ConfigResolver.java
----------------------------------------------------------------------
diff --git a/deltaspike/core/api/src/main/java/org/apache/deltaspike/core/api/config/ConfigResolver.java b/deltaspike/core/api/src/main/java/org/apache/deltaspike/core/api/config/ConfigResolver.java
index 7ef2c52..98de4f1 100644
--- a/deltaspike/core/api/src/main/java/org/apache/deltaspike/core/api/config/ConfigResolver.java
+++ b/deltaspike/core/api/src/main/java/org/apache/deltaspike/core/api/config/ConfigResolver.java
@@ -885,14 +885,14 @@ public final class ConfigResolver
@Override
public T getValue()
{
+ long now = -1;
if (cacheTimeMs > 0)
{
- long now = System.currentTimeMillis();
+ now = System.currentTimeMillis();
if (now <= reloadAfter)
{
return lastValue;
}
- reloadAfter = now + cacheTimeMs;
}
String valueStr = resolveStringValue();
@@ -909,6 +909,7 @@ public final class ConfigResolver
if (cacheTimeMs > 0)
{
lastValue = value;
+ reloadAfter = now + cacheTimeMs;
}
return value;