Merge pull request #1 from pallu87/patch-1

Update WeightedRoundRobin.java
This commit is contained in:
Gaurav Sen 2020-09-23 18:45:19 +05:30 committed by GitHub
commit 5f0b1effd0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -34,7 +34,7 @@ public class WeightedRoundRobin implements Router {
public Node getAssignedNode(Request request) { public Node getAssignedNode(Request request) {
synchronized (this.lock) { synchronized (this.lock) {
assignTo = assignTo % nodes.size(); assignTo = (assignTo + nodes.size()) % nodes.size();
final var currentNode = nodes.get(assignTo); final var currentNode = nodes.get(assignTo);
currentNodeAssignments++; currentNodeAssignments++;
if (currentNodeAssignments == currentNode.getWeight()) { if (currentNodeAssignments == currentNode.getWeight()) {