summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2022-04-04 10:59:59 +0200
committerGitHub <noreply@github.com>2022-04-04 10:59:59 +0200
commitf0664db5ab90a0bfd3bd190f7bd0a34019a645ac (patch)
treeb284481b2563a8552a1bd8563e38723a7bb016bb /configserver
parentb7a0c3fac30cce9d012318cb08bcd62ea0b3c2cf (diff)
parenta65eeb0c470abaac519efe442fd011e26ca2509b (diff)
Merge pull request #21918 from vespa-engine/jonmv/misc-6
Jonmv/misc 6
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponses.java7
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java8
2 files changed, 5 insertions, 10 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponses.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponses.java
index d3976464bde..7e6fccb6d2f 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponses.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponses.java
@@ -193,10 +193,9 @@ public class DelayedConfigResponses {
}
private synchronized void metricDelayedResponses(ApplicationId app, int elems) {
- if ( ! metrics.containsKey(app)) {
- metrics.put(app, rpcServer.metricUpdaterFactory().getOrCreateMetricUpdater(Metrics.createDimensions(app)));
- }
- metrics.get(app).setDelayedResponses(elems);
+ metrics.computeIfAbsent(app, key -> rpcServer.metricUpdaterFactory()
+ .getOrCreateMetricUpdater(Metrics.createDimensions(key)))
+ .setDelayedResponses(elems);
}
private synchronized void createQueueIfNotExists(GetConfigContext context) {
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
index 99ffff6403b..ebf1fb32141 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
@@ -243,13 +243,9 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
}
private ApplicationState getState(ApplicationId id) {
- ApplicationState state = applicationStateMap.get(id);
- if (state == null) {
- applicationStateMap.putIfAbsent(id, new ApplicationState(0));
- state = applicationStateMap.get(id);
- }
- return state;
+ return applicationStateMap.computeIfAbsent(id, __ -> new ApplicationState(0));
}
+
boolean hasNewerGeneration(ApplicationId id, long generation) {
return getState(id).getActiveGeneration() > generation;
}