aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@oath.com>2018-02-23 15:41:26 +0100
committerTor Brede Vekterli <vekterli@oath.com>2018-02-27 16:05:50 +0100
commit9063ffeccfa036493390bb09741448c232151cdf (patch)
tree10460a25295206050f42fc97f01a8a14966c409f /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
parent86029a0a0eefacc98b5c86cd8921eed98f4882e6 (diff)
Add v3 RPC for sending cluster states to content nodes
Supports sending states for multiple bucket spaces at once, with possibilities for extending protocol later for sending distribution config etc. Payload is LZ4-compressed when possible. If a receiver node does not understand the v3 protocol, the protocol version is transparently downgraded to legacy v2 RPC.
Diffstat (limited to 'clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java')
-rw-r--r--clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
index a6e62d29ab5..ae59336b5ef 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
@@ -17,8 +17,9 @@ public class DistributionBitCountTest extends FleetControllerTest {
private void setUpSystem(String testName) throws Exception {
List<ConfiguredNode> configuredNodes = new ArrayList<>();
- for (int i = 0 ; i < 10; i++)
+ for (int i = 0 ; i < 10; i++) {
configuredNodes.add(new ConfiguredNode(i, false));
+ }
FleetControllerOptions options = new FleetControllerOptions("mycluster", configuredNodes);
options.distributionBits = 17;
setUpFleetController(false, options);