public class FIFOBandwidthRefiller extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BURST_SECONDS |
static int |
DEFAULT_INBOUND_BANDWIDTH |
static int |
DEFAULT_INBOUND_BURST_BANDWIDTH |
static int |
DEFAULT_OUTBOUND_BANDWIDTH
Caution, do not make DEFAULT_OUTBOUND_BANDWIDTH * DEFAULT_SHARE_PCT > 32
without thinking about the implications (default connection limits, for example)
of moving the default bandwidth class from L to M, or maybe
adjusting bandwidth class boundaries.
|
static int |
DEFAULT_OUTBOUND_BURST_BANDWIDTH |
static int |
MAX_OUTBOUND_BANDWIDTH
Max for reasonable Bloom filter false positive rate.
|
static int |
MIN_INBOUND_BANDWIDTH
For now, until there is some tuning and safe throttling, we set the floor at this inbound (KBps)
|
static int |
MIN_INBOUND_BANDWIDTH_PEAK
For now, until there is some tuning and safe throttling, we set the floor at this during burst (KBps)
|
static int |
MIN_OUTBOUND_BANDWIDTH
For now, until there is some tuning and safe throttling, we set the floor at this outbound (KBps)
|
static int |
MIN_OUTBOUND_BANDWIDTH_PEAK
For now, until there is some tuning and safe throttling, we set the floor at this during burst (KBps)
|
static String |
PROP_INBOUND_BANDWIDTH |
static String |
PROP_INBOUND_BANDWIDTH_PEAK |
static String |
PROP_INBOUND_BURST_BANDWIDTH |
static String |
PROP_OUTBOUND_BANDWIDTH |
static String |
PROP_OUTBOUND_BANDWIDTH_PEAK |
static String |
PROP_OUTBOUND_BURST_BANDWIDTH |
Constructor and Description |
---|
FIFOBandwidthRefiller(I2PAppContext context,
FIFOBandwidthLimiter limiter) |
Modifier and Type | Method and Description |
---|---|
(package private) int |
getCurrentParticipatingBandwidth()
Out bandwidth.
|
(package private) int |
getInboundBurstKBytesPerSecond() |
(package private) int |
getInboundKBytesPerSecond() |
(package private) int |
getOutboundBurstKBytesPerSecond() |
(package private) int |
getOutboundKBytesPerSecond() |
(package private) void |
incrementParticipatingMessageBytes(int size)
We sent a message.
|
(package private) void |
reinitialize() |
void |
run() |
(package private) void |
shutdown() |
public static final String PROP_INBOUND_BANDWIDTH
public static final String PROP_OUTBOUND_BANDWIDTH
public static final String PROP_INBOUND_BURST_BANDWIDTH
public static final String PROP_OUTBOUND_BURST_BANDWIDTH
public static final String PROP_INBOUND_BANDWIDTH_PEAK
public static final String PROP_OUTBOUND_BANDWIDTH_PEAK
public static final int DEFAULT_INBOUND_BANDWIDTH
public static final int DEFAULT_OUTBOUND_BANDWIDTH
public static final int DEFAULT_INBOUND_BURST_BANDWIDTH
public static final int DEFAULT_OUTBOUND_BURST_BANDWIDTH
public static final int DEFAULT_BURST_SECONDS
public static final int MIN_INBOUND_BANDWIDTH
public static final int MIN_OUTBOUND_BANDWIDTH
public static final int MIN_INBOUND_BANDWIDTH_PEAK
public static final int MIN_OUTBOUND_BANDWIDTH_PEAK
public static final int MAX_OUTBOUND_BANDWIDTH
FIFOBandwidthRefiller(I2PAppContext context, FIFOBandwidthLimiter limiter)
void shutdown()
void reinitialize()
int getOutboundKBytesPerSecond()
int getInboundKBytesPerSecond()
int getOutboundBurstKBytesPerSecond()
int getInboundBurstKBytesPerSecond()
void incrementParticipatingMessageBytes(int size)
size
- bytesint getCurrentParticipatingBandwidth()