Package | Description |
---|---|
bt.magnet | |
bt.module | |
bt.net | |
bt.net.crypto | |
bt.net.pipeline | |
bt.peerexchange | |
bt.protocol | |
bt.protocol.extended | |
bt.protocol.handler | |
bt.torrent.compiler | |
bt.torrent.messaging |
Modifier and Type | Class and Description |
---|---|
class |
UtMetadata
BEP-9 extension message.
|
Modifier and Type | Method and Description |
---|---|
<M extends Message> |
ProtocolModuleExtender.addMessageHandler(int messageType,
Class<? extends MessageHandler<M>> handlerType)
Contribute a message handler type, that will process BEP-3 messages with the given ID.
|
<M extends Message> |
ProtocolModuleExtender.addMessageHandler(int messageType,
MessageHandler<M> handler)
Contribute a message handler instance, that will process BEP-3 messages with the given ID.
|
Modifier and Type | Method and Description |
---|---|
static com.google.inject.multibindings.MapBinder<Integer,MessageHandler<? extends Message>> |
ProtocolModule.contributeMessageHandler(com.google.inject.Binder binder)
Deprecated.
since 1.5 in favor of
ProtocolModuleExtender.addMessageHandler(int, Class) and its' overloaded versions |
Modifier and Type | Method and Description |
---|---|
IPeerConnectionFactory |
ServiceModule.providePeerConnectionFactory(SharedSelector selector,
IConnectionHandlerFactory connectionHandlerFactory,
MessageHandler<Message> bittorrentProtocol,
TorrentRegistry torrentRegistry,
IChannelPipelineFactory channelPipelineFactory,
IBufferManager bufferManager,
DataReceiver dataReceiver,
EventSource eventSource,
Config config) |
Modifier and Type | Method and Description |
---|---|
Message |
PeerConnection.readMessage(long timeout)
Attempt to read an incoming message within a specified time interval.
|
Message |
SocketPeerConnection.readMessage(long timeout) |
Message |
PeerConnection.readMessageNow()
Attempt to read an incoming message.
|
Message |
SocketPeerConnection.readMessageNow() |
Modifier and Type | Method and Description |
---|---|
void |
PeerConnection.postMessage(Message message)
Send a message to remote peer.
|
void |
SocketPeerConnection.postMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
IMessageDispatcher.addMessageConsumer(ConnectionKey connectionKey,
Consumer<Message> messageConsumer)
Add a message consumer to receive messages from a remote peer for a given torrent.
|
void |
MessageDispatcher.addMessageConsumer(ConnectionKey connectionKey,
Consumer<Message> messageConsumer) |
void |
IMessageDispatcher.addMessageSupplier(ConnectionKey connectionKey,
Supplier<Message> messageSupplier)
Add a message supplier to send messages to a remote peer for a given torrent.
|
void |
MessageDispatcher.addMessageSupplier(ConnectionKey connectionKey,
Supplier<Message> messageSupplier) |
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 |
---|
MSEHandshakeProcessor(TorrentRegistry torrentRegistry,
MessageHandler<Message> protocol,
Config config) |
Modifier and Type | Method and Description |
---|---|
Message |
DefaultChannelPipeline.decode() |
Message |
ChannelPipeline.decode() |
Message |
InboundMessageProcessor.pollMessage() |
Message |
ChannelHandler.receive() |
Message |
SocketChannelHandler.receive() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultChannelPipeline.encode(Message message) |
boolean |
ChannelPipeline.encode(Message message) |
void |
ChannelHandler.send(Message message) |
void |
SocketChannelHandler.send(Message message) |
Modifier and Type | Method and Description |
---|---|
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) |
ChannelPipelineBuilder |
ChannelPipelineBuilder.protocol(MessageHandler<Message> protocol) |
Constructor and Description |
---|
DefaultChannelPipeline(Peer peer,
MessageHandler<Message> protocol,
BorrowedBuffer<ByteBuffer> inboundBuffer,
BorrowedBuffer<ByteBuffer> outboundBuffer,
List<BufferMutator> decoders,
List<BufferMutator> encoders,
IBufferedPieceRegistry bufferedPieceRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
PeerExchangePeerSourceFactory.produce(Consumer<Message> messageConsumer,
MessageContext messageContext) |
Modifier and Type | Class and Description |
---|---|
class |
Bitfield |
class |
Cancel |
class |
Choke |
class |
Handshake
Standard handshake message.
|
class |
Have |
class |
Interested |
class |
KeepAlive |
class |
NotInterested |
class |
Piece |
class |
Port |
class |
Request |
class |
Unchoke |
Modifier and Type | Method and Description |
---|---|
Message |
DecodingContext.getMessage() |
Modifier and Type | Method and Description |
---|---|
Collection<Class<? extends Message>> |
StandardBittorrentProtocol.getSupportedTypes() |
Class<? extends Message> |
StandardBittorrentProtocol.readMessageType(ByteBufferView buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
StandardBittorrentProtocol.encode(EncodingContext context,
Message message,
ByteBuffer buffer) |
void |
DecodingContext.setMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
static void |
Protocols.verifyPayloadHasLength(Class<? extends Message> type,
int expectedLength,
int actualLength)
Convenience method to check if actual message length is the same as expected length.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtendedHandshake
Extended handshake is sent during connection initialization procedure
by peers that support BEP-10: Extension Protocol.
|
class |
ExtendedMessage
Base class for all extended messages.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseMessageHandler<T extends Message>
Base class for
MessageHandler implementations, that work with a single message type. |
interface |
MessageHandler<T extends Message>
Message encoder/decoder.
|
class |
UniqueMessageHandler<T extends Message> |
Modifier and Type | Method and Description |
---|---|
<T extends Message> |
CompilerVisitor.visitConsumer(Class<T> consumedType,
MethodHandle handle)
Visit a message consumer method.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MessageConsumer<T extends Message>
Message agent, that is interested in receiving messages of type T
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageRouter.consume(Message message,
MessageContext context) |
void |
MessageRouter.consume(Message message,
MessageContext context)
Route a message to consumers.
|
Modifier and Type | Method and Description |
---|---|
void |
PieceConsumer.produce(Consumer<Message> messageConsumer) |
void |
DefaultMessageRouter.produce(Consumer<Message> messageConsumer,
MessageContext context) |
void |
RequestProducer.produce(Consumer<Message> messageConsumer,
MessageContext context) |
void |
PeerRequestConsumer.produce(Consumer<Message> messageConsumer,
MessageContext context) |
void |
MetadataConsumer.produce(Consumer<Message> messageConsumer,
MessageContext context) |
void |
MessageProducer.produce(Consumer<Message> messageConsumer,
MessageContext context)
Produce a message to the remote peer, if possible
|
void |
MetadataProducer.produce(Consumer<Message> messageConsumer,
MessageContext context) |
void |
MessageRouter.produce(Consumer<Message> messageConsumer,
MessageContext context)
Request a message from producers.
|
Copyright © 2016–2021. All rights reserved.