diff options
| author | Tor Brede Vekterli <vekterli@oath.com> | 2018-06-11 17:26:23 +0200 |
|---|---|---|
| committer | Tor Brede Vekterli <vekterli@oath.com> | 2018-06-11 17:26:23 +0200 |
| commit | be579425c40efc330e9b78b27024c1ea79dec1a2 (patch) | |
| tree | f27f9386886e6a2508b78ab8ab88a124eeb9b2b6 /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc | |
| parent | 8ec25d827c1cefa65d23b34a00284e1558bb1164 (diff) | |
Remove support for ancient legacy node state protocol versions
Protocol versions 0 and 1 haven't been in use for years. No point
in maintaining complexity to support automatic downgrades to these.
Diffstat (limited to 'clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc')
| -rw-r--r-- | clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicatorTest.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicatorTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicatorTest.java index 2665175c637..7602f0c83a2 100644 --- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicatorTest.java +++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicatorTest.java @@ -3,6 +3,9 @@ package com.yahoo.vespa.clustercontroller.core.rpc; import com.yahoo.jrt.*; import com.yahoo.vdslib.state.Node; +import com.yahoo.vdslib.state.NodeState; +import com.yahoo.vdslib.state.NodeType; +import com.yahoo.vdslib.state.State; import com.yahoo.vespa.clustercontroller.core.*; import org.junit.Test; import org.mockito.Mockito; @@ -87,6 +90,8 @@ public class RPCCommunicatorTest { when(target.isValid()).thenReturn(true); when(nodeInfo.getConnection()).thenReturn(target); + when(nodeInfo.getVersion()).thenReturn(3); + when(nodeInfo.getReportedState()).thenReturn(new NodeState(NodeType.DISTRIBUTOR, State.UP)); communicator.getNodeState(nodeInfo, null); Mockito.verify(target).invokeAsync( (Request)any(), |