summaryrefslogtreecommitdiffstats
path: root/vdslib
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@verizonmedia.com>2021-03-12 16:35:18 +0100
committerGitHub <noreply@github.com>2021-03-12 16:35:18 +0100
commitd4dacaaa3a7fa0dc79c467f25bb68de99c023771 (patch)
treec2bfacfdec47ab72e3c1a3467cd435240d1861b7 /vdslib
parent79ce87f9297b978e7c1720b1fd1caf58307c8626 (diff)
parenta7ed8446ffbb642c1fb6855f6d0271f4aef66a9c (diff)
Merge pull request #16926 from vespa-engine/vekterli/dont-store-full-bundle-objects-in-state-history
Don't store full bundle objects in state history
Diffstat (limited to 'vdslib')
-rw-r--r--vdslib/src/main/java/com/yahoo/vdslib/state/ClusterState.java16
-rw-r--r--vdslib/src/test/java/com/yahoo/vdslib/state/ClusterStateTestCase.java8
2 files changed, 3 insertions, 21 deletions
diff --git a/vdslib/src/main/java/com/yahoo/vdslib/state/ClusterState.java b/vdslib/src/main/java/com/yahoo/vdslib/state/ClusterState.java
index b13b6230d3e..c536fc0f4cd 100644
--- a/vdslib/src/main/java/com/yahoo/vdslib/state/ClusterState.java
+++ b/vdslib/src/main/java/com/yahoo/vdslib/state/ClusterState.java
@@ -30,7 +30,6 @@ public class ClusterState implements Cloneable {
private String description = "";
private int distributionBits = 16;
- private boolean official = false;
public ClusterState(String serialized) throws ParseException {
nodeCount.add(0);
@@ -169,16 +168,6 @@ public class ClusterState implements Cloneable {
: DEFAULT_DISTRIBUTOR_UP_NODE_STATE;
}
- /**
- * Fleet controller marks states that are actually sent out to nodes as official states. Only fleetcontroller
- * should set this to official, and only just before sending it out. This state is currently not serialized with
- * the system state, but only used internally in the fleetcontroller. Might be useful client side though, where
- * clients modify states to mark nodes down that they cannot speak with.
- */
- public void setOfficial(boolean official) { this.official = official; }
- /** Whether this system state is an unmodified version of an official system state. */
- public boolean isOfficial() { return official; }
-
/** Used during deserialization */
private class NodeData {
@@ -202,7 +191,6 @@ public class ClusterState implements Cloneable {
}
private void deserialize(String serialized) throws ParseException {
- official = false;
StringTokenizer st = new StringTokenizer(serialized, " \t\n\f\r", false);
NodeData nodeData = new NodeData();
String lastAbsolutePath = "";
@@ -323,9 +311,6 @@ public class ClusterState implements Cloneable {
if (distributionBits != other.distributionBits) {
diff.add(new Diff.Entry("bits", distributionBits, other.distributionBits));
}
- if (official != other.official) {
- diff.add(new Diff.Entry("official", official, other.official));
- }
for (NodeType type : NodeType.getTypes()) {
Diff typeDiff = new Diff();
int maxCount = Math.max(getNodeCount(type), other.getNodeCount(type));
@@ -348,7 +333,6 @@ public class ClusterState implements Cloneable {
}
public void setVersion(int version) {
- official = false;
this.version = version;
}
diff --git a/vdslib/src/test/java/com/yahoo/vdslib/state/ClusterStateTestCase.java b/vdslib/src/test/java/com/yahoo/vdslib/state/ClusterStateTestCase.java
index 258a79f5362..dbc8888cfda 100644
--- a/vdslib/src/test/java/com/yahoo/vdslib/state/ClusterStateTestCase.java
+++ b/vdslib/src/test/java/com/yahoo/vdslib/state/ClusterStateTestCase.java
@@ -188,9 +188,8 @@ public class ClusterStateTestCase{
state2.setDistributionBits(21);
state1.setVersion(123);
state1.setNodeState(new Node(NodeType.STORAGE, 2), new NodeState(NodeType.STORAGE, State.INITIALIZING).setInitProgress(0.2f).setDescription("Booting"));
- state2.setOfficial(true);
- assertEquals("version: 123 => 0, bits: 16 => 21, official: false => true, storage: [2: [Initializing => Up, description: Booting => ], 4: Down => Up, 5: Down => Up], distributor: [7: Up => Down, 8: Up => Down]", state1.getTextualDifference(state2));
+ assertEquals("version: 123 => 0, bits: 16 => 21, storage: [2: [Initializing => Up, description: Booting => ], 4: Down => Up, 5: Down => Up], distributor: [7: Up => Down, 8: Up => Down]", state1.getTextualDifference(state2));
}
@Test
@@ -221,9 +220,8 @@ public class ClusterStateTestCase{
state1.setVersion(123);
state1.setNodeState(new Node(NodeType.STORAGE, 2), new NodeState(NodeType.STORAGE, State.INITIALIZING).setInitProgress(0.2f).setDescription("Booting"));
state2.setDistributionBits(21);
- state2.setOfficial(true);
- assertEquals("version: 123 => 0, bits: 16 => 21, official: false => true, storage: [2: [Initializing => Up, description: Booting => ], 4: Down => Up, 5: Down => Up], distributor: [7: Up => Down, 8: Up => Down]", state1.getTextualDifference(state2));
- assertEquals("version: 123 =&gt; 0, bits: 16 =&gt; 21, official: false =&gt; true, storage: [<br>\n" +
+ assertEquals("version: 123 => 0, bits: 16 => 21, storage: [2: [Initializing => Up, description: Booting => ], 4: Down => Up, 5: Down => Up], distributor: [7: Up => Down, 8: Up => Down]", state1.getTextualDifference(state2));
+ assertEquals("version: 123 =&gt; 0, bits: 16 =&gt; 21, storage: [<br>\n" +
"&nbsp;2: [<b>Initializing</b> =&gt; <b>Up</b>, description: Booting =&gt; ], <br>\n" +
"&nbsp;4: <b>Down</b> =&gt; <b>Up</b>, <br>\n" +
"&nbsp;5: <b>Down</b> =&gt; <b>Up</b><br>\n" +