Package | Description |
---|---|
bt.dht | |
bt.event | |
bt.net | |
bt.net.crypto | |
bt.net.pipeline | |
bt.peer | |
bt.protocol | |
bt.torrent.data | |
bt.torrent.messaging | |
bt.tracker |
Modifier and Type | Method and Description |
---|---|
Stream<Peer> |
MldhtService.getPeers(Torrent torrent) |
Stream<Peer> |
DHTService.getPeers(Torrent torrent)
Deprecated.
since 1.3 in favor of
DHTService.getPeers(TorrentId) |
Stream<Peer> |
MldhtService.getPeers(TorrentId torrentId) |
Stream<Peer> |
DHTService.getPeers(TorrentId torrentId)
Creates a peer lookup for a given torrent.
|
Modifier and Type | Method and Description |
---|---|
void |
MldhtService.addNode(Peer node) |
void |
DHTService.addNode(Peer node)
Add a DHT node.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DHTPeerSource.collectPeers(Consumer<Peer> peerConsumer) |
Modifier and Type | Method and Description |
---|---|
Peer |
PeerConnectedEvent.getPeer() |
Peer |
PeerDisconnectedEvent.getPeer() |
Peer |
PeerBitfieldUpdatedEvent.getPeer() |
Peer |
PeerDiscoveredEvent.getPeer() |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
PeerDiscoveredEvent(long id,
long timestamp,
TorrentId torrentId,
Peer peer) |
Modifier and Type | Class and Description |
---|---|
class |
InetPeer |
Modifier and Type | Method and Description |
---|---|
Peer |
ConnectionKey.getPeer() |
Peer |
PeerConnection.getRemotePeer() |
Peer |
SocketPeerConnection.getRemotePeer() |
Modifier and Type | Method and Description |
---|---|
void |
PeerConnectionPool.checkDuplicateConnections(TorrentId torrentId,
Peer peer) |
void |
IPeerConnectionPool.checkDuplicateConnections(TorrentId torrentId,
Peer peer) |
ConnectionResult |
PeerConnectionFactory.createIncomingConnection(Peer peer,
SocketChannel channel) |
ConnectionResult |
IPeerConnectionFactory.createIncomingConnection(Peer peer,
SocketChannel channel) |
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.
|
Constructor and Description |
---|
ConnectionKey(Peer peer,
int remotePort,
TorrentId torrentId) |
Modifier and Type | Method and Description |
---|---|
Optional<MSECipher> |
MSEHandshakeProcessor.negotiateIncoming(Peer peer,
ByteChannel channel,
ByteBuffer in,
ByteBuffer out) |
Optional<MSECipher> |
MSEHandshakeProcessor.negotiateOutgoing(Peer peer,
ByteChannel channel,
TorrentId torrentId,
ByteBuffer in,
ByteBuffer out) |
Modifier and Type | Method and Description |
---|---|
ChannelPipelineBuilder |
ChannelPipelineFactory.buildPipeline(Peer peer) |
ChannelPipelineBuilder |
IChannelPipelineFactory.buildPipeline(Peer peer)
Start building a pipeline for the given peer.
|
protected abstract ChannelPipeline |
ChannelPipelineBuilder.doBuild(Peer peer,
ByteChannel channel,
MessageHandler<Message> protocol,
Optional<BorrowedBuffer<ByteBuffer>> inboundBuffer,
Optional<BorrowedBuffer<ByteBuffer>> outboundBuffer,
List<BufferMutator> decoders,
List<BufferMutator> encoders) |
Constructor and Description |
---|
DefaultChannelPipeline(Peer peer,
MessageHandler<Message> protocol,
BorrowedBuffer<ByteBuffer> inboundBuffer,
BorrowedBuffer<ByteBuffer> outboundBuffer,
List<BufferMutator> decoders,
List<BufferMutator> encoders,
IBufferedPieceRegistry bufferedPieceRegistry) |
InboundMessageProcessor(Peer peer,
ByteBuffer buffer,
bt.net.pipeline.MessageDeserializer deserializer,
List<BufferMutator> decoders,
IBufferedPieceRegistry bufferedPieceRegistry) |
Modifier and Type | Method and Description |
---|---|
Peer |
IPeerRegistry.getLocalPeer()
Returns local peer, that represents current runtime in the swarm.
|
Peer |
PeerRegistry.getLocalPeer() |
Modifier and Type | Method and Description |
---|---|
Collection<Peer> |
PeerSource.getPeers()
Get the list of peers.
|
Collection<Peer> |
ScheduledPeerSource.getPeers() |
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) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
ScheduledPeerSource.collectPeers(Consumer<Peer> peerConsumer) |
Modifier and Type | Method and Description |
---|---|
Peer |
DecodingContext.getPeer() |
Peer |
EncodingContext.getPeer() |
Constructor and Description |
---|
DecodingContext(Peer peer)
Create a decoding context for a particular peer.
|
EncodingContext(Peer peer) |
Modifier and Type | Method and Description |
---|---|
Peer |
BlockRead.getPeer() |
Peer |
BlockWrite.getPeer() |
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) |
Modifier and Type | Method and Description |
---|---|
Peer |
MessageContext.getPeer() |
Modifier and Type | Method and Description |
---|---|
Iterable<Peer> |
TrackerResponse.getPeers() |
Iterator<Peer> |
CompactPeerInfo.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
TrackerResponse.setPeers(Iterable<Peer> peers) |
Copyright © 2016–2021. All rights reserved.