summaryrefslogtreecommitdiffstats
path: root/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java
diff options
context:
space:
mode:
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java')
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java13
1 files changed, 6 insertions, 7 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java
index 54e18302ef6..c1e580794b4 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/LegacyLoadBalancer.java
@@ -30,7 +30,8 @@ class LegacyLoadBalancer extends LoadBalancer {
* @param choices the node choices, represented as Slobrok entries
* @return the chosen node, or null only if the given choices were zero
*/
- public Node getRecipient(List<Mirror.Entry> choices) {
+ @Override
+ Node getRecipient(List<Mirror.Entry> choices) {
if (choices.isEmpty()) return null;
double weightSum = 0.0;
@@ -56,6 +57,7 @@ class LegacyLoadBalancer extends LoadBalancer {
return selectedNode;
}
+ @Override
protected NodeMetrics createNodeMetrics() {
return new LegacyNodeMetrics();
}
@@ -66,15 +68,12 @@ class LegacyLoadBalancer extends LoadBalancer {
LegacyNodeMetrics n = (LegacyNodeMetrics) nodeMetrics;
if (n == null) continue;
double want = n.weight * 1.01010101010101010101;
- if (want >= 1.0) {
- n.weight = want;
- } else {
- n.weight = 1.0;
- }
+ n.weight = Math.max(1.0, want);
}
}
- public void received(Node node, boolean busy) {
+ @Override
+ void received(Node node, boolean busy) {
if (busy) {
synchronized (this) {
LegacyNodeMetrics n = (LegacyNodeMetrics) node.metrics;