PeerTestJob (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.JobImpl
- - net.i2p.router.peermanager.PeerTestJob

All Implemented Interfaces:
Job
```
public class PeerTestJob
extends JobImpl
```
Periodically tests selected peers to gather real-time performance data and update peer profiles.
This job runs continuously when enabled, selecting peers based on bandwidth tier, reachability, and version compatibility. Tests are performed by sending a DatabaseStoreMessage containing the peer's own RouterInfo back to itself through the tunnel system, measuring response times and connectivity.
Peer Selection Criteria:
- High-bandwidth tiers (O, P, X) with reachability capability
- Version 0.9.57+ for compatibility
- Configurable concurrency based on system resources
Performance Impact:
- Adaptive delays based on system load and uptime
- CPU throttling when load exceeds 80%
- Automatic timeout adjustment based on historical test times
Future Considerations:
- Evaluate necessity of peer testing in current network conditions
- Consider alternative test methods beyond RI self-messaging
- Integration with PeerManager.selectPeers() optimization

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`PROP_PEER_TEST_CONCURRENCY` PROP_PEER_TEST_CONCURRENCY.
`static String`	`PROP_PEER_TEST_DELAY` PROP_PEER_TEST_DELAY.
`static String`	`PROP_PEER_TEST_TIMEOUT` PROP_PEER_TEST_TIMEOUT.

Fields inherited from class net.i2p.router.JobImpl
_id

Constructor Summary
Constructors
Constructor and Description
PeerTestJob(RouterContext context)
Creates a new PeerTestJob instance and initializes required statistics.

Constructors
Constructor and Description
`PeerTestJob(RouterContext context)` Creates a new PeerTestJob instance and initializes required statistics.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`getAvgPeerTestTime()` Gets the average successful peer test time over the last minute.
`String`	`getName()` Descriptive name of the task
`int`	`getTotalAvgPeerTestTime()` Gets the total average peer test time including both successful and slow tests over the last hour.
`void`	`runJob()` Main job execution loop that performs peer testing with adaptive scheduling.
`void`	`schedulePriorityTests(List<Hash> peers)` Schedule peers for priority testing (e.g., from slow tunnels).
`void`	`startTesting(PeerManager manager)` Starts the peer testing process with adaptive initial delay.
`void`	`stopTesting()` Stops the peer testing process gracefully.

Methods inherited from class net.i2p.router.JobImpl
dropped, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - PROP_PEER_TEST_CONCURRENCY
```
public static final String PROP_PEER_TEST_CONCURRENCY
```
    PROP_PEER_TEST_CONCURRENCY.
    See Also:
    Constant Field Values
  - PROP_PEER_TEST_DELAY
```
public static final String PROP_PEER_TEST_DELAY
```
    PROP_PEER_TEST_DELAY.
    See Also:
    Constant Field Values
  - PROP_PEER_TEST_TIMEOUT
```
public static final String PROP_PEER_TEST_TIMEOUT
```
    PROP_PEER_TEST_TIMEOUT.
    See Also:
    Constant Field Values
- Constructor Detail
  - PeerTestJob
```
public PeerTestJob(RouterContext context)
```
    Creates a new PeerTestJob instance and initializes required statistics.
    Parameters:
    context - the router context for accessing services like logging and statistics
- Method Detail
  - getAvgPeerTestTime
```
public int getAvgPeerTestTime()
```
    Gets the average successful peer test time over the last minute.
    Returns:
    average test time in milliseconds, or 0 if no context available
  - getName
```
public String getName()
```
    Description copied from interface: Job
    Descriptive name of the task
    Returns:
    the name
  - getTotalAvgPeerTestTime
```
public int getTotalAvgPeerTestTime()
```
    Gets the total average peer test time including both successful and slow tests over the last hour.
    Returns:
    total average test time in milliseconds, or 0 if no context available
  - runJob
```
public void runJob()
```
    Main job execution loop that performs peer testing with adaptive scheduling. Process flow:
    1. Check if testing should continue
    2. Select peers for testing based on criteria
    3. Test each selected peer
    4. Adapt next run delay based on system conditions
    Adaptive Behavior:
    - Double delay if job lag > 300ms (system overload)
    - Double delay if CPU load > 80% (resource conservation)
    - Normal delay otherwise
  - schedulePriorityTests
```
public void schedulePriorityTests(List<Hash> peers)
```
    Schedule peers for priority testing (e.g., from slow tunnels). These peers will be tested on the next test cycle before other peers.
    Parameters:
    peers - list of peer hashes to test urgently
  - startTesting
```
public void startTesting(PeerManager manager)
```
    Starts the peer testing process with adaptive initial delay.
    Schedules the first test run based on router uptime:
    - If uptime < 3 minutes: wait 3 minutes before starting
    - Otherwise: start immediately with configured delay
    Parameters:
    manager - the peer manager to use for peer selection
  - stopTesting
```
public void stopTesting()
```
    Stops the peer testing process gracefully.
    The current test round will complete, but no new rounds will be scheduled.

Class PeerTestJob

Field Summary

Fields inherited from class net.i2p.router.JobImpl

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.JobImpl

Methods inherited from class java.lang.Object

Field Detail

PROP_PEER_TEST_CONCURRENCY

PROP_PEER_TEST_DELAY

PROP_PEER_TEST_TIMEOUT

Constructor Detail

PeerTestJob

Method Detail

getAvgPeerTestTime

getName

getTotalAvgPeerTestTime

runJob

schedulePriorityTests

startTesting

stopTesting