Package | Description |
---|---|
bt.data | |
bt.dht | |
bt.event | |
bt.module | |
bt.net | |
bt.peer | |
bt.peer.lan | |
bt.peerexchange | |
bt.processor | |
bt.processor.torrent | |
bt.runtime | |
bt.torrent | |
bt.torrent.data | |
bt.torrent.messaging |
Constructor and Description |
---|
DataReaderFactory(EventSource eventSource) |
Constructor and Description |
---|
MldhtService(IRuntimeLifecycleBinder lifecycleBinder,
Config config,
DHTConfig dhtConfig,
Set<PortMapper> portMappers,
TorrentRegistry torrentRegistry,
EventSource eventSource) |
Modifier and Type | Class and Description |
---|---|
class |
EventBus
Basic implementation of event bus, that connects event producers and listeners.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
IDataDescriptorFactory |
ServiceModule.provideDataDescriptorFactory(Config config,
EventSource eventSource,
ChunkVerifier verifier) |
IPeerConnectionFactory |
ServiceModule.providePeerConnectionFactory(SharedSelector selector,
IConnectionHandlerFactory connectionHandlerFactory,
MessageHandler<Message> bittorrentProtocol,
TorrentRegistry torrentRegistry,
IChannelPipelineFactory channelPipelineFactory,
IBufferManager bufferManager,
DataReceiver dataReceiver,
EventSource eventSource,
Config config) |
Constructor and Description |
---|
PeerConnectionFactory(Selector selector,
IConnectionHandlerFactory connectionHandlerFactory,
IChannelPipelineFactory channelPipelineFactory,
MessageHandler<Message> protocol,
TorrentRegistry torrentRegistry,
IBufferManager bufferManager,
DataReceiver dataReceiver,
EventSource eventSource,
Config config) |
Constructor and Description |
---|
PeerRegistry(IRuntimeLifecycleBinder lifecycleBinder,
EventSource eventSource,
IdentityService idService,
TorrentRegistry torrentRegistry,
ITrackerService trackerService,
EventSink eventSink,
Set<PeerSourceFactory> extraPeerSourceFactories,
Config config) |
Constructor and Description |
---|
LocalServiceDiscoveryService(Cookie cookie,
ILocalServiceDiscoveryInfo info,
Collection<AnnounceGroupChannel> groupChannels,
EventSource eventSource,
IRuntimeLifecycleBinder lifecycleBinder,
LocalServiceDiscoveryConfig config) |
Constructor and Description |
---|
PeerExchangePeerSourceFactory(EventSource eventSource,
IRuntimeLifecycleBinder lifecycleBinder,
PeerExchangeConfig pexConfig,
Config config) |
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 |
---|
CreateSessionStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry,
EventSource eventSource,
IConnectionSource connectionSource,
IMessageDispatcher messageDispatcher,
Set<Object> messagingAgents,
Config config) |
Modifier and Type | Method and Description |
---|---|
EventSource |
BtRuntime.getEventSource() |
Constructor and Description |
---|
AdhocTorrentRegistry(IDataDescriptorFactory dataDescriptorFactory,
EventSource eventSource) |
Constructor and Description |
---|
LRUBlockCache(TorrentRegistry torrentRegistry,
EventSource eventSource) |
Constructor and Description |
---|
TorrentWorker(TorrentId torrentId,
IMessageDispatcher dispatcher,
IConnectionSource connectionSource,
IPeerWorkerFactory peerWorkerFactory,
Supplier<LocalBitfield> bitfieldSupplier,
Supplier<Assignments> assignmentsSupplier,
Supplier<BitfieldBasedStatistics> statisticsSupplier,
EventSource eventSource,
Config config) |
Copyright © 2016–2021. All rights reserved.