experiment

Author: robertroeser

proteus-client/src/main/java/io/netifi/proteus/rsocket/WeightedReconnectingRSocket.java

@@ -483,6 +483,7 @@ private synchronized long instantaneous(long now) {
   private synchronized long start() {
     long now = Clock.now();
     pending += 1;
+    stamp = now;
     return now;
   }
 
@@ -542,6 +543,11 @@ public long lastTimeUsedMillis() {
   public double availability() {
     if (Clock.now() - stamp > tau) {
       recordError(1.0);
+      double m = interArrivalTime.value();
+      if (m > 0) {
+        m *= 0.5;
+        record(m);
+      }
     }
     return availability * errorPercentage.value();
   }