aboutsummaryrefslogtreecommitdiffstats
path: root/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-11-27 10:35:20 +0100
committerJon Bratseth <bratseth@gmail.com>2020-11-27 10:35:20 +0100
commit0facde033e35dbd0510c095519e322667ba278bd (patch)
tree50a840996e7c47a4287488bfd03dd04c4f49427e /config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
parent7a60abe577e6cd9cbbe2b3aa62d7220ff5b191ec (diff)
Revert "Merge pull request #15495 from vespa-engine/revert-15494-bratseth/apply-on-restart-take-2"
This reverts commit ef4ece0ae64a1f1ec8accb257168b2a08d6971b1, reversing changes made to 204eb6f5faf91a6159ba5c7e01d2d8b6f307e8bd.
Diffstat (limited to 'config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java')
-rw-r--r--config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java14
1 files changed, 12 insertions, 2 deletions
diff --git a/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java b/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
index eec18b93e71..ba8fc8a5e19 100644
--- a/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
+++ b/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
@@ -18,7 +18,6 @@ import static java.util.logging.Level.FINE;
* Used by config proxy.
*
* @author Vegard Havdal
- *
*/
public class GenericJRTConfigSubscription extends JRTConfigSubscription<RawConfig> {
@@ -33,7 +32,7 @@ public class GenericJRTConfigSubscription extends JRTConfigSubscription<RawConfi
@Override
protected void setNewConfig(JRTClientConfigRequest jrtReq) {
- setConfig(jrtReq.getNewGeneration(), jrtReq.responseIsInternalRedeploy(), RawConfig.createFromResponseParameters(jrtReq) );
+ setConfig(jrtReq.getNewGeneration(), jrtReq.responseIsInternalRedeploy(), jrtReq.responseIsApplyOnRestart(), RawConfig.createFromResponseParameters(jrtReq) );
log.log(FINE, () -> "in setNewConfig, config=" + this.getConfigState().getConfig());
}
@@ -60,6 +59,17 @@ public class GenericJRTConfigSubscription extends JRTConfigSubscription<RawConfi
}
}
+ // Override to propagate internal redeploy into the config value in addition to the config state
+ @Override
+ void setApplyOnRestart(boolean applyOnRestart) {
+ super.setApplyOnRestart(applyOnRestart);
+ ConfigState<RawConfig> configState = getConfigState();
+
+ if (configState.getConfig() != null) {
+ configState.getConfig().setApplyOnRestart(applyOnRestart);
+ }
+ }
+
public RawConfig getRawConfig() {
return getConfigState().getConfig();
}