java.lang.Runnable
public class FIFOBandwidthRefiller
extends java.lang.Object
implements java.lang.Runnable
修飾子とタイプ | フィールド | 説明 |
---|---|---|
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 java.lang.String |
PROP_INBOUND_BANDWIDTH |
|
static java.lang.String |
PROP_INBOUND_BANDWIDTH_PEAK |
|
static java.lang.String |
PROP_INBOUND_BURST_BANDWIDTH |
|
static java.lang.String |
PROP_OUTBOUND_BANDWIDTH |
|
static java.lang.String |
PROP_OUTBOUND_BANDWIDTH_PEAK |
|
static java.lang.String |
PROP_OUTBOUND_BURST_BANDWIDTH |
コンストラクタ | 説明 |
---|---|
FIFOBandwidthRefiller(I2PAppContext context,
FIFOBandwidthLimiter limiter) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
(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 java.lang.String PROP_INBOUND_BANDWIDTH
public static final java.lang.String PROP_OUTBOUND_BANDWIDTH
public static final java.lang.String PROP_INBOUND_BURST_BANDWIDTH
public static final java.lang.String PROP_OUTBOUND_BURST_BANDWIDTH
public static final java.lang.String PROP_INBOUND_BANDWIDTH_PEAK
public static final java.lang.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()
public void run()
run
インタフェース内 java.lang.Runnable
void reinitialize()
int getOutboundKBytesPerSecond()
int getInboundKBytesPerSecond()
int getOutboundBurstKBytesPerSecond()
int getInboundBurstKBytesPerSecond()
void incrementParticipatingMessageBytes(int size)
size
- bytesint getCurrentParticipatingBandwidth()