Modifier and Type | Method and Description |
---|---|
Stream<Peer> |
MldhtService.getPeers(TorrentId torrentId) |
Stream<Peer> |
DHTService.getPeers(TorrentId torrentId)
Creates a peer lookup for a given torrent.
|
PeerSource |
DHTPeerSourceFactory.getPeerSource(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
TorrentId |
TorrentEvent.getTorrentId() |
TorrentId |
MetadataAvailableEvent.getTorrentId() |
TorrentId |
TorrentStartedEvent.getTorrentId() |
TorrentId |
PeerConnectedEvent.getTorrentId() |
TorrentId |
TorrentStoppedEvent.getTorrentId() |
TorrentId |
PeerDisconnectedEvent.getTorrentId() |
TorrentId |
PeerBitfieldUpdatedEvent.getTorrentId() |
TorrentId |
PieceVerifiedEvent.getTorrentId() |
TorrentId |
PeerDiscoveredEvent.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
void |
EventSink.fireMetadataAvailable(TorrentId torrentId,
Torrent torrent)
Generate event, that torrent's metadata has been fetched.
|
void |
EventBus.fireMetadataAvailable(TorrentId torrentId,
Torrent torrent) |
void |
EventSink.firePeerBitfieldUpdated(TorrentId torrentId,
ConnectionKey connectionKey,
Bitfield bitfield)
Generate event, that local information about some peer's data has been updated.
|
void |
EventBus.firePeerBitfieldUpdated(TorrentId torrentId,
ConnectionKey connectionKey,
Bitfield bitfield) |
void |
EventSink.firePeerDiscovered(TorrentId torrentId,
Peer peer)
Generate event, that a new peer has been discovered for some torrent.
|
void |
EventBus.firePeerDiscovered(TorrentId torrentId,
Peer peer) |
void |
EventSink.firePieceVerified(TorrentId torrentId,
int pieceIndex)
Generate event, that the downloading and verification
of one of torrent's pieces has been finished.
|
void |
EventBus.firePieceVerified(TorrentId torrentId,
int pieceIndex) |
void |
EventSink.fireTorrentStarted(TorrentId torrentId)
Generate event, that processing of some torrent has begun.
|
void |
EventBus.fireTorrentStarted(TorrentId torrentId) |
void |
EventSink.fireTorrentStopped(TorrentId torrentId)
Generate event, that processing of some torrent has finished.
|
void |
EventBus.fireTorrentStopped(TorrentId torrentId) |
EventSource |
EventSource.onMetadataAvailable(TorrentId torrentId,
Consumer<MetadataAvailableEvent> listener)
Fired, when torrent's metadata has been fetched.
|
EventSource |
EventBus.onMetadataAvailable(TorrentId torrentId,
Consumer<MetadataAvailableEvent> listener) |
EventSource |
EventSource.onPeerBitfieldUpdated(TorrentId torrentId,
Consumer<PeerBitfieldUpdatedEvent> listener)
Fired, when local information about some peer's data has been updated.
|
EventSource |
EventBus.onPeerBitfieldUpdated(TorrentId torrentId,
Consumer<PeerBitfieldUpdatedEvent> listener) |
EventSource |
EventSource.onPeerConnected(TorrentId torrentId,
Consumer<PeerConnectedEvent> listener)
Fired, when a new connection with some peer has been established.
|
EventSource |
EventBus.onPeerConnected(TorrentId torrentId,
Consumer<PeerConnectedEvent> listener) |
EventSource |
EventSource.onPeerDisconnected(TorrentId torrentId,
Consumer<PeerDisconnectedEvent> listener)
Fired, when a connection with some peer has been terminated.
|
EventSource |
EventBus.onPeerDisconnected(TorrentId torrentId,
Consumer<PeerDisconnectedEvent> listener) |
EventSource |
EventSource.onPeerDiscovered(TorrentId torrentId,
Consumer<PeerDiscoveredEvent> listener)
Fired, when a new peer has been discovered for some torrent.
|
EventSource |
EventBus.onPeerDiscovered(TorrentId torrentId,
Consumer<PeerDiscoveredEvent> listener) |
EventSource |
EventSource.onPieceVerified(TorrentId torrentId,
Consumer<PieceVerifiedEvent> listener)
Fired, when downloading and verification of one of torrent's pieces has been finished.
|
EventSource |
EventBus.onPieceVerified(TorrentId torrentId,
Consumer<PieceVerifiedEvent> listener) |
EventSource |
EventSource.onTorrentStarted(TorrentId torrentId,
Consumer<TorrentStartedEvent> listener)
Fired, when processing of some torrent has begun.
|
EventSource |
EventBus.onTorrentStarted(TorrentId torrentId,
Consumer<TorrentStartedEvent> listener) |
EventSource |
EventSource.onTorrentStopped(TorrentId torrentId,
Consumer<TorrentStoppedEvent> listener)
Fired, when processing of some torrent has finished.
|
EventSource |
EventBus.onTorrentStopped(TorrentId torrentId,
Consumer<TorrentStoppedEvent> listener) |
Constructor and Description |
---|
MetadataAvailableEvent(long id,
long timestamp,
TorrentId torrentId,
Torrent torrent) |
PeerDiscoveredEvent(long id,
long timestamp,
TorrentId torrentId,
Peer peer) |
PieceVerifiedEvent(long id,
long timestamp,
TorrentId torrentId,
int pieceIndex) |
TorrentStartedEvent(long id,
long timestamp,
TorrentId torrentId) |
TorrentStoppedEvent(long id,
long timestamp,
TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
TorrentId |
MagnetUri.getTorrentId()
Represents the "xt" parameter.
|
Modifier and Type | Method and Description |
---|---|
static MagnetUri.Builder |
MagnetUri.torrentId(TorrentId torrentId)
Start building a magnet link for a given torrent.
|
Constructor and Description |
---|
Builder(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
static TorrentId |
TorrentId.fromBytes(byte[] bytes)
Create a TorrentId instance from a binary representation.
|
TorrentId |
Torrent.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
TorrentId |
PeerConnection.getTorrentId() |
TorrentId |
SocketPeerConnection.getTorrentId() |
TorrentId |
ConnectionKey.getTorrentId() |
TorrentId |
PeerConnection.setTorrentId(TorrentId torrentId)
Associate this connection with the given torrent ID.
|
TorrentId |
SocketPeerConnection.setTorrentId(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
void |
PeerConnectionPool.checkDuplicateConnections(TorrentId torrentId,
Peer peer) |
void |
IPeerConnectionPool.checkDuplicateConnections(TorrentId torrentId,
Peer peer) |
ConnectionResult |
PeerConnectionFactory.createOutgoingConnection(Peer peer,
TorrentId torrentId) |
ConnectionResult |
IPeerConnectionFactory.createOutgoingConnection(Peer peer,
TorrentId torrentId) |
PeerConnection |
PeerConnectionPool.getConnection(Peer peer,
TorrentId torrentId) |
ConnectionResult |
ConnectionSource.getConnection(Peer peer,
TorrentId torrentId) |
PeerConnection |
IPeerConnectionPool.getConnection(Peer peer,
TorrentId torrentId) |
ConnectionResult |
IConnectionSource.getConnection(Peer peer,
TorrentId torrentId)
Deprecated.
This is no longer used
|
CompletableFuture<ConnectionResult> |
ConnectionSource.getConnectionAsync(Peer peer,
TorrentId torrentId) |
CompletableFuture<ConnectionResult> |
IConnectionSource.getConnectionAsync(Peer peer,
TorrentId torrentId)
Get connection for a given peer and torrent ID asynchronously.
|
ConnectionHandler |
ConnectionHandlerFactory.getOutgoingHandler(TorrentId torrentId) |
ConnectionHandler |
IConnectionHandlerFactory.getOutgoingHandler(TorrentId torrentId) |
TorrentId |
PeerConnection.setTorrentId(TorrentId torrentId)
Associate this connection with the given torrent ID.
|
TorrentId |
SocketPeerConnection.setTorrentId(TorrentId torrentId) |
void |
PeerConnectionPool.visitConnections(TorrentId torrentId,
Consumer<PeerConnection> visitor) |
void |
IPeerConnectionPool.visitConnections(TorrentId torrentId,
Consumer<PeerConnection> visitor)
Visit connections for a given torrent ID.
|
Constructor and Description |
---|
ConnectionKey(Peer peer,
int remotePort,
TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
Optional<MSECipher> |
MSEHandshakeProcessor.negotiateOutgoing(Peer peer,
ByteChannel channel,
TorrentId torrentId,
ByteBuffer in,
ByteBuffer out) |
Modifier and Type | Method and Description |
---|---|
void |
IPeerRegistry.addPeer(TorrentId torrentId,
Peer peer)
Add peer for a given torrent and notify all peer consumers.
|
void |
PeerRegistry.addPeer(TorrentId torrentId,
Peer peer) |
void |
IPeerRegistry.addPeerSource(TorrentId torrentId,
AnnounceKey announceKey)
Register a new tracker peer source for a given torrent, based on the provided announce key.
|
void |
PeerRegistry.addPeerSource(TorrentId torrentId,
AnnounceKey announceKey) |
PeerSource |
PeerSourceFactory.getPeerSource(TorrentId torrentId)
Create a peer source for a given torrent.
|
void |
IPeerRegistry.triggerPeerCollection(TorrentId torrentId)
Trigger a collection of peers for the specified torrent.
|
void |
PeerRegistry.triggerPeerCollection(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
PeerSource |
LocalServiceDiscoveryPeerSourceFactory.getPeerSource(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
PeerSource |
PeerExchangePeerSourceFactory.getPeerSource(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
Optional<TorrentId> |
ProcessingContext.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
Optional<TorrentId> |
MagnetContext.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
void |
MagnetContext.setTorrentId(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
Optional<TorrentId> |
TorrentContext.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
void |
TorrentContext.setTorrentId(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
TorrentId |
Handshake.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
Handshake |
IHandshakeFactory.createHandshake(TorrentId torrentId)
Create a handshake, that can be used
to initialize peer connections for a given torrent.
|
Handshake |
HandshakeFactory.createHandshake(TorrentId torrentId) |
ExtendedHandshake |
IExtendedHandshakeFactory.getHandshake(TorrentId torrentId) |
Constructor and Description |
---|
Handshake(byte[] reserved,
TorrentId torrentId,
PeerId peerId) |
Modifier and Type | Method and Description |
---|---|
static MSECipher |
MSECipher.forInitiator(byte[] S,
TorrentId torrentId)
Create MSE cipher for connection initiator
|
static MSECipher |
MSECipher.forReceiver(byte[] S,
TorrentId torrentId)
Create MSE cipher for receiver of the connection request
|
Modifier and Type | Method and Description |
---|---|
ExtendedHandshake |
ExtendedHandshakeFactory.getHandshake(TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
Collection<TorrentId> |
AdhocTorrentRegistry.getTorrentIds() |
Collection<TorrentId> |
TorrentRegistry.getTorrentIds()
Get all torrents, that have been registered in the runtime.
|
Modifier and Type | Method and Description |
---|---|
Optional<TorrentDescriptor> |
AdhocTorrentRegistry.getDescriptor(TorrentId torrentId) |
Optional<TorrentDescriptor> |
TorrentRegistry.getDescriptor(TorrentId torrentId)
Get a torrent descriptor for a given torrent, if exists.
|
Optional<Torrent> |
AdhocTorrentRegistry.getTorrent(TorrentId torrentId) |
Optional<Torrent> |
TorrentRegistry.getTorrent(TorrentId torrentId)
Get a torrent with a given torrent ID, if exists.
|
boolean |
AdhocTorrentRegistry.isSupportedAndActive(TorrentId torrentId) |
boolean |
TorrentRegistry.isSupportedAndActive(TorrentId torrentId) |
TorrentDescriptor |
AdhocTorrentRegistry.register(TorrentId torrentId) |
TorrentDescriptor |
TorrentRegistry.register(TorrentId torrentId)
Get an existing torrent descriptor for a given torrent ID
or create a new one if it does not exist.
|
void |
AdhocTorrentRegistry.registerSessionState(TorrentId torrentId,
TorrentSessionState state) |
void |
TorrentRegistry.registerSessionState(TorrentId torrentId,
TorrentSessionState state)
Register a session state for the specified torrent
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<BlockWrite> |
DataWorker.addBlock(TorrentId torrentId,
Peer peer,
int pieceIndex,
int offset,
BufferedData buffer)
Add a write block request.
|
CompletableFuture<BlockWrite> |
DefaultDataWorker.addBlock(TorrentId torrentId,
Peer peer,
int pieceIndex,
int offset,
BufferedData buffer) |
CompletableFuture<BlockRead> |
DataWorker.addBlockRequest(TorrentId torrentId,
Peer peer,
int pieceIndex,
int offset,
int length)
Add a read block request.
|
CompletableFuture<BlockRead> |
DefaultDataWorker.addBlockRequest(TorrentId torrentId,
Peer peer,
int pieceIndex,
int offset,
int length) |
BlockReader |
BlockCache.get(TorrentId torrentId,
int pieceIndex,
int offset,
int length) |
BlockReader |
NoCache.get(TorrentId torrentId,
int pieceIndex,
int offset,
int length) |
BlockReader |
LRUBlockCache.get(TorrentId torrentId,
int pieceIndex,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
TorrentId |
MessageContext.getTorrentId() |
Constructor and Description |
---|
MetadataConsumer(IMetadataService metadataService,
TorrentId torrentId,
Config config) |
PeerRequestConsumer(TorrentId torrentId,
DataWorker dataWorker) |
PieceConsumer(TorrentId torrentId,
Bitfield bitfield,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink) |
TorrentWorker(TorrentId torrentId,
IMessageDispatcher dispatcher,
IConnectionSource connectionSource,
IPeerWorkerFactory peerWorkerFactory,
Supplier<LocalBitfield> bitfieldSupplier,
Supplier<Assignments> assignmentsSupplier,
Supplier<BitfieldBasedStatistics> statisticsSupplier,
EventSource eventSource,
Config config) |
Modifier and Type | Method and Description |
---|---|
TorrentId |
TrackerRequestBuilder.getTorrentId() |
Modifier and Type | Method and Description |
---|---|
TrackerRequestBuilder |
Tracker.request(TorrentId torrentId)
Build a tracker request for a given torrent.
|
Constructor and Description |
---|
TrackerRequestBuilder(TorrentId torrentId)
Create a tracker request builder for a given torrent ID
|
Modifier and Type | Method and Description |
---|---|
TrackerRequestBuilder |
HttpTracker.request(TorrentId torrentId) |
Copyright © 2016–2021. All rights reserved.