minor fixes in weighted algorithm formula

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/loadbalance/BaseWeightedStats.java

@@ -33,8 +33,6 @@ public class BaseWeightedStats implements WeightedStats {
   private long stamp0; // last timestamp we sent a request or receive a response
   private long duration; // instantaneous cumulative duration
 
-  private double availability = 1.0;
-
   private volatile int pendingRequests; // instantaneous rate
   private static final AtomicIntegerFieldUpdater<BaseWeightedStats> PENDING_REQUESTS =
       AtomicIntegerFieldUpdater.newUpdater(BaseWeightedStats.class, "pendingRequests");
@@ -87,7 +85,7 @@ public double availability() {
     if (Clock.now() - stamp > tau) {
       updateAvailability(1.0);
     }
-    return availability * availabilityPercentage.value();
+    return availabilityPercentage.value();
   }
 
   @Override
@@ -181,10 +179,6 @@ void updateAvailability(double value) {
     }
   }
 
-  void setAvailability(double availability) {
-    this.availability = availability;
-  }
-
   @Override
   public String toString() {
     return "Stats{"
@@ -215,7 +209,7 @@ public String toString() {
         + ", pendingStreams="
         + pendingStreams
         + ", availability="
-        + availability
+        + availabilityPercentage.value()
         + '}';
   }
 }

rsocket-core/src/main/java/io/rsocket/loadbalance/WeightedLoadbalanceStrategy.java

@@ -159,7 +159,8 @@ private static double algorithmicWeight(
       latency *= calculateFactor(latency, high, bandWidth);
     }
 
-    return rSocket.availability() / (1.0d + latency * (pending + 1));
+    return (rSocket.availability() * weightedStats.availability())
+        / (1.0d + latency * (pending + 1));
   }
 
   private static double calculateFactor(final double u, final double l, final double bandWidth) {