diff options
author | Harald Musum <musum@verizonmedia.com> | 2023-03-06 07:56:59 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-03-06 07:56:59 +0100 |
commit | 0c7d07ee7f4e485c3218316859640b1a448e39c6 (patch) | |
tree | ae82a2e38c0d83996bc601902ee0c2a29933b634 | |
parent | a70fd9b92c0eeb637e6b0955e31cf324377afbde (diff) | |
parent | 1c9d2acca42e2087f2a8f3e77ba1ff23ae1d307c (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.java | 10 |
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); }); } |