ConnectionAcceptor (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- org.klomp.snark.ConnectionAcceptor

All Implemented Interfaces:
Runnable
```
class ConnectionAcceptor
extends Object
implements Runnable
```
Accepts incoming I2P connections and routes them to the appropriate PeerAcceptor.
This class manages the main I2P server socket that listens for incoming peer connections and routes them to the correct PeerAcceptor based on the torrent's info hash. It handles:
- Listening on the I2P server socket for incoming connections
- Basic connection validation and handshake parsing
- Routing connections to the appropriate PeerAcceptor
- Connection rate limiting and blacklisting of misbehaving peers
- Thread management for accepting connections
- Cleanup of stale connection data
The acceptor supports multi-torrent operation by working with a PeerCoordinatorSet to determine which torrent a connection belongs to based on the info hash in the BitTorrent handshake.
When multi-dest is enabled, each torrent additionally runs a TorrentAcceptLoop on its own server socket, so that incoming connections are received on the torrent's own destination.
Connections that repeatedly fail protocol validation may be temporarily blacklisted to prevent abuse.

Constructor Summary

Constructors
Constructor and Description
`ConnectionAcceptor(I2PSnarkUtil util, PeerAcceptor peeracceptor)` Unused (single torrent).
`ConnectionAcceptor(I2PSnarkUtil util, PeerAcceptor peeracceptor, TorrentDest td)` Single torrent on its own destination.
`ConnectionAcceptor(I2PSnarkUtil util, PeerCoordinatorSet set)` Multitorrent.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addTorrentAcceptor(TorrentDest td, PeerCoordinator coordinator)` Start an accept loop on a torrent's destination, adding the torrent to the destination's loop when one already runs for a pooled destination.
`void`	`ban(Hash h)` Ban the given hash.
`int`	`getPort()` Returns the port this acceptor is listening on.
`void`	`halt()` May be restarted later with startAccepting().
`boolean`	`isBanned(Hash h)` Is the given hash banned?
`void`	`removeTorrentAcceptor(TorrentDest td, PeerCoordinator coordinator)` Remove a torrent from its destination's accept loop, halting the loop when it no longer serves any torrent.
`void`	`restart()` Effectively unused, would only be called if we changed I2CP host/port, which is hidden in the gui if in router context
`void`	`run()`
`void`	`startAccepting()` May be called even when already running.

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

- Constructor Detail
  - ConnectionAcceptor
```
public ConnectionAcceptor(I2PSnarkUtil util,
                          PeerAcceptor peeracceptor)
```
    Unused (single torrent). Do NOT call startAccepting().
  - ConnectionAcceptor
```
public ConnectionAcceptor(I2PSnarkUtil util,
                          PeerAcceptor peeracceptor,
                          TorrentDest td)
```
    Single torrent on its own destination. Do NOT call startAccepting().
  - ConnectionAcceptor
```
public ConnectionAcceptor(I2PSnarkUtil util,
                          PeerCoordinatorSet set)
```
    Multitorrent. Caller MUST call startAccepting()
- Method Detail
  - addTorrentAcceptor
```
public void addTorrentAcceptor(TorrentDest td,
                               PeerCoordinator coordinator)
```
    Start an accept loop on a torrent's destination, adding the torrent to the destination's loop when one already runs for a pooled destination. Multitorrent only.
    Parameters:
    td - the torrent's destination
    coordinator - the torrent's peer coordinator
  - ban
```
public void ban(Hash h)
```
    Ban the given hash.
    Parameters:
    h - the hash
  - getPort
```
public int getPort()
```
    Returns the port this acceptor is listening on.
    Returns:
    the port number
  - halt
```
public void halt()
```
    May be restarted later with startAccepting().
  - isBanned
```
public boolean isBanned(Hash h)
```
    Is the given hash banned?
    Parameters:
    h - the hash
    Returns:
    true if banned
  - removeTorrentAcceptor
```
public void removeTorrentAcceptor(TorrentDest td,
                                  PeerCoordinator coordinator)
```
    Remove a torrent from its destination's accept loop, halting the loop when it no longer serves any torrent. Multitorrent only.
    Parameters:
    td - the torrent's destination, or null if it never got one
    coordinator - the torrent's peer coordinator
  - restart
```
public void restart()
```
    Effectively unused, would only be called if we changed I2CP host/port, which is hidden in the gui if in router context
  - run
```
public void run()
```
    Specified by:
    run in interface Runnable
  - startAccepting
```
public void startAccepting()
```
    May be called even when already running. May be called to start up again after halt().

Class ConnectionAcceptor

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ConnectionAcceptor

ConnectionAcceptor

ConnectionAcceptor

Method Detail

addTorrentAcceptor

ban

getPort

halt

isBanned

removeTorrentAcceptor

restart

run

startAccepting