class BatchedRouterPreprocessor extends BatchedPreprocessor
| Modifier and Type | Field and Description |
|---|---|
protected HopConfig | _hopConfigthe hop config for inbound gateways |
static int | DEFAULT_BATCH_FREQUENCYfor IBGWs for efficiency (not our data) |
static int | OB_CLIENT_BATCH_FREQfor client OBGWs only (our data) |
static int | OB_EXPL_BATCH_FREQfor exploratory OBGWs only (our tunnel tests and build messages) |
static String | PROP_BATCH_FREQUENCYHow frequently should we flush non-full messages, in milliseconds
This goes in I2CP custom options for the pool. |
static String | PROP_ROUTER_BATCH_FREQUENCYThis goes in router advanced config |
DEFAULT_DELAY_context, _dataCache, _log, IV_SIZE, PREPROCESSED_SIZE| Constructor and Description |
|---|
BatchedRouterPreprocessor(RouterContext ctx,
HopConfig cfg)Create a preprocessor for inbound gateway tunnels. |
BatchedRouterPreprocessor(RouterContext ctx,
TunnelCreatorConfig cfg)Create a preprocessor for outbound gateway tunnels. |
| Modifier and Type | Method and Description |
|---|---|
protected long | getSendDelay()how long should we wait before flushing |
protected void | notePreprocessing(long messageId,
int numFragments,
int totalLength,
List<Long> messageIds,
String msg)Note preprocessing statistics. |
getDelayAmount, preprocessQueue, sendgetInstructionAugmentationSize, getInstructionsSize, preprocess, writeFirstFragment, writeSubsequentFragmentprotected final HopConfig _hopConfig
public static final int DEFAULT_BATCH_FREQUENCY
public static final int OB_CLIENT_BATCH_FREQ
public static final int OB_EXPL_BATCH_FREQ
public static final String PROP_BATCH_FREQUENCY
public static final String PROP_ROUTER_BATCH_FREQUENCY
public BatchedRouterPreprocessor(RouterContext ctx, HopConfig cfg)
ctx - the router contextcfg - the hop configpublic BatchedRouterPreprocessor(RouterContext ctx, TunnelCreatorConfig cfg)
ctx - the router contextcfg - the tunnel creator configprotected long getSendDelay()
getSendDelay in class BatchedPreprocessorprotected void notePreprocessing(long messageId,
int numFragments,
int totalLength,
List<Long> messageIds,
String msg)TrivialPreprocessornotePreprocessing in class TrivialPreprocessor