Package | Description |
---|---|
bt.net.pipeline | |
bt.processor | |
bt.processor.magnet | |
bt.processor.torrent | |
bt.torrent.messaging |
Modifier and Type | Class and Description |
---|---|
class |
BufferedPieceRegistry |
Constructor and Description |
---|
ChannelPipelineFactory(IBufferManager bufferManager,
IBufferedPieceRegistry bufferedPieceRegistry) |
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) |
Constructor and Description |
---|
TorrentProcessorFactory(TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
ITrackerService trackerService,
ExecutorService executor,
IPeerRegistry peerRegistry,
IConnectionSource connectionSource,
IPeerConnectionPool connectionPool,
IMessageDispatcher messageDispatcher,
Set<Object> messagingAgents,
IMetadataService metadataService,
EventSource eventSource,
EventSink eventSink,
Config config) |
Constructor and Description |
---|
InitializeMagnetTorrentProcessingStage(ProcessingStage<MagnetContext> next,
IPeerConnectionPool connectionPool,
TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink,
Config config) |
Constructor and Description |
---|
InitializeTorrentProcessingStage(ProcessingStage<C> next,
IPeerConnectionPool connectionPool,
TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink,
Config config) |
Constructor and Description |
---|
PieceConsumer(TorrentId torrentId,
Bitfield bitfield,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink) |
Copyright © 2016–2021. All rights reserved.