Util: Consolidate dup BandwidthEstimator interfaces

This commit is contained in:
zzz
2021-03-09 07:37:51 -05:00
parent c1c2f4bb2e
commit 731bf920f6
7 changed files with 24 additions and 40 deletions

View File

@@ -1,20 +0,0 @@
package net.i2p.client.streaming.impl;
/**
* A Westwood bandwidth estimator
*
* @since 0.9.46
*/
interface BandwidthEstimator {
/**
* Records an arriving ack.
* @param acked how many packets were acked with this ack
*/
public void addSample(int acked);
/**
* @return the current bandwidth estimate in packets/ms.
*/
public float getBandwidthEstimate();
}

View File

@@ -17,6 +17,7 @@ import net.i2p.client.streaming.I2PSocketException;
import net.i2p.data.DataHelper;
import net.i2p.data.Destination;
import net.i2p.data.SigningPublicKey;
import net.i2p.util.BandwidthEstimator;
import net.i2p.util.Log;
import net.i2p.util.SimpleTimer;
import net.i2p.util.SimpleTimer2;

View File

@@ -2,6 +2,7 @@ package net.i2p.client.streaming.impl;
import net.i2p.I2PAppContext;
import net.i2p.data.DataHelper;
import net.i2p.util.BandwidthEstimator;
import net.i2p.util.Log;
/**

View File

@@ -0,0 +1,20 @@
package net.i2p.util;
/**
* A Westwood bandwidth estimator
*
* @since 0.9.46 consolidated from streaming and udp in 0.9.50
*/
public interface BandwidthEstimator {
/**
* Records an arriving ack.
* @param acked how many bytes or packets were acked with this ack
*/
public void addSample(int acked);
/**
* @return the current bandwidth estimate in bytes/ms or packets/ms.
*/
public float getBandwidthEstimate();
}

View File

@@ -1,20 +0,0 @@
package net.i2p.router.transport.udp;
/**
* A Westwood bandwidth estimator
*
* @since 0.9.49 adapted from streaming
*/
interface BandwidthEstimator {
/**
* Records an arriving ack.
* @param acked how many bytes were acked with this ack
*/
public void addSample(int acked);
/**
* @return the current bandwidth estimate in bytes/ms.
*/
public float getBandwidthEstimate();
}

View File

@@ -24,6 +24,7 @@ import net.i2p.router.transport.udp.InboundMessageFragments.ModifiableLong;
import net.i2p.router.util.CachedIteratorCollection;
import net.i2p.router.util.CoDelPriorityBlockingQueue;
import net.i2p.router.util.PriBlockingQueue;
import net.i2p.util.BandwidthEstimator;
import net.i2p.util.Log;
import net.i2p.util.ConcurrentHashSet;

View File

@@ -2,6 +2,7 @@ package net.i2p.router.transport.udp;
import net.i2p.I2PAppContext;
import net.i2p.data.DataHelper;
import net.i2p.util.BandwidthEstimator;
import net.i2p.util.Log;
/**