TunnelGateway.QueuePreprocessorclass BatchedRouterPreprocessor extends BatchedPreprocessor
| 修飾子とタイプ | フィールド | 説明 |
|---|---|---|
protected HopConfig |
_hopConfig |
|
static int |
DEFAULT_BATCH_FREQUENCY |
for IBGWs for efficiency (not our data)
|
static int |
OB_CLIENT_BATCH_FREQ |
for client OBGWs only (our data)
|
static int |
OB_EXPL_BATCH_FREQ |
for exploratory OBGWs only (our tunnel tests and build messages)
|
static java.lang.String |
PROP_BATCH_FREQUENCY |
How frequently should we flush non-full messages, in milliseconds
This goes in I2CP custom options for the pool.
|
static java.lang.String |
PROP_ROUTER_BATCH_FREQUENCY |
This goes in router advanced config
|
DEFAULT_DELAY_context, _dataCache, _log, IV_SIZE, PREPROCESSED_SIZE| コンストラクタ | 説明 |
|---|---|
BatchedRouterPreprocessor(RouterContext ctx,
HopConfig cfg) |
for IBGWs
|
BatchedRouterPreprocessor(RouterContext ctx,
TunnelCreatorConfig cfg) |
for OBGWs
|
| 修飾子とタイプ | メソッド | 説明 |
|---|---|---|
protected long |
getSendDelay() |
how long should we wait before flushing
|
protected void |
notePreprocessing(long messageId,
int numFragments,
int totalLength,
java.util.List<java.lang.Long> messageIds,
java.lang.String msg) |
getDelayAmount, preprocessQueue, sendclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetInstructionAugmentationSize, getInstructionsSize, preprocess, writeFirstFragment, writeSubsequentFragmentprotected final HopConfig _hopConfig
public static final java.lang.String PROP_BATCH_FREQUENCY
public static final java.lang.String PROP_ROUTER_BATCH_FREQUENCY
public static final int OB_CLIENT_BATCH_FREQ
public static final int OB_EXPL_BATCH_FREQ
public static final int DEFAULT_BATCH_FREQUENCY
public BatchedRouterPreprocessor(RouterContext ctx, TunnelCreatorConfig cfg)
public BatchedRouterPreprocessor(RouterContext ctx, HopConfig cfg)
protected long getSendDelay()
getSendDelay クラス内 BatchedPreprocessorprotected void notePreprocessing(long messageId,
int numFragments,
int totalLength,
java.util.List<java.lang.Long> messageIds,
java.lang.String msg)
notePreprocessing クラス内 TrivialPreprocessor