class PeerCoordinatorSet extends Object implements Iterable<PeerCoordinator>
This class provides a centralized registry for PeerCoordinator objects, enabling the multi-torrent functionality in I2PSnark. It is primarily used by:
The set maps torrent info hashes to their corresponding PeerCoordinator instances, allowing efficient lookup by torrent identifier. All operations are thread-safe through ConcurrentHashMap.
Each PeerCoordinator is automatically added when a torrent starts and removed when the torrent stops, ensuring the set always reflects currently active torrents.
| Constructor and Description |
|---|
PeerCoordinatorSet()Creates a new empty PeerCoordinatorSet. |
| Modifier and Type | Method and Description |
|---|---|
void | add(PeerCoordinator coordinator)Register a coordinator for its torrent's info hash. |
PeerCoordinator | get(byte[] infoHash) |
Iterator<PeerCoordinator> | iterator()Returns an iterator over all registered coordinators. |
void | remove(PeerCoordinator coordinator)Unregister a coordinator. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorpublic PeerCoordinatorSet()
public void add(PeerCoordinator coordinator)
coordinator - the coordinatorpublic PeerCoordinator get(byte[] infoHash)
public Iterator<PeerCoordinator> iterator()
iterator in interface Iterable<PeerCoordinator>public void remove(PeerCoordinator coordinator)
coordinator - the coordinator