summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2023-03-06 07:56:59 +0100
committerGitHub <noreply@github.com>2023-03-06 07:56:59 +0100
commit0c7d07ee7f4e485c3218316859640b1a448e39c6 (patch)
treeae82a2e38c0d83996bc601902ee0c2a29933b634
parenta70fd9b92c0eeb637e6b0955e31cf324377afbde (diff)
parent1c9d2acca42e2087f2a8f3e77ba1ff23ae1d307c (diff)
Merge pull request #26288 from vespa-engine/hmusum/resolve-config-when-we-discover-that-a-new-config-generation-is-active
Resolve config when we discover a new config generation is active
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java10
1 files changed, 5 insertions, 5 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java
index 5e7fff8c922..c916a429599 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java
@@ -152,12 +152,12 @@ class GetConfigProcessor implements Runnable {
delayed.ifPresent(d -> {
GetConfigContext context = d.context();
- rpcServer.delayResponse(request, context);
- if (rpcServer.hasNewerGeneration(context.applicationId(), d.generation())) {
+ if (rpcServer.hasNewerGeneration(context.applicationId(), d.generation()))
// This will ensure that if the config activation train left the station while I was boarding,
- // another train will immediately be scheduled.
- rpcServer.configActivated(context.applicationId());
- }
+ // we will resolve config again with new generation
+ resolveConfig(request);
+ else
+ rpcServer.delayResponse(request, context);
});
}