Package | Description |
---|---|
net.tomp2p.connection | |
net.tomp2p.futures | |
net.tomp2p.message | |
net.tomp2p.p2p | |
net.tomp2p.rpc |
Modifier and Type | Method and Description |
---|---|
void |
SenderNetty.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator) |
void |
Sender.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator)
Sent the message via UDP broadcast.
|
void |
SenderNetty.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator,
int idleTCPMillis) |
void |
Sender.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator,
int idleTCPMillis)
Sent the message via TCP.
|
void |
SenderNetty.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator) |
void |
Sender.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler,
FutureResponse futureResponse,
Message message,
ChannelCreator channelCreator)
Sent the message via UDP.
|
Modifier and Type | Method and Description |
---|---|
Message |
FutureResponse.getRequest()
The future response always keeps a reference to the request.
|
Message |
FutureResponse.getResponse()
Returns the response message.
|
Modifier and Type | Method and Description |
---|---|
BaseFuture.FutureType |
FutureSuccessEvaluatorOperation.evaluate(Message requestMessage,
Message responseMessage) |
BaseFuture.FutureType |
FutureSuccessEvaluatorCommunication.evaluate(Message requestMessage,
Message responseMessage) |
BaseFuture.FutureType |
FutureSuccessEvaluator.evaluate(Message requestMessage,
Message responseMessage) |
void |
FutureResponse.setResponse(Message responseMessage)
Gets called if a peer responds.
|
Constructor and Description |
---|
FutureResponse(Message requestMessage)
Create the future and set the request message
|
FutureResponse(Message requestMessage,
boolean raw) |
FutureResponse(Message requestMessage,
FutureSuccessEvaluator futureSuccessEvaluator) |
FutureResponse(Message requestMessage,
FutureSuccessEvaluator futureSuccessEvaluator,
boolean raw)
Create the future and set the request message
|
Modifier and Type | Method and Description |
---|---|
protected Message |
TomP2PDecoderUDP.decode(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.Channel channel,
org.jboss.netty.buffer.ChannelBuffer buffer,
SocketAddress socketAddress) |
static Message |
MessageCodec.decodeHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
InetSocketAddress recipient,
InetSocketAddress sender)
Decode a message header from a Netty buffer
|
Message |
Message.replaceDataMap(Map<Number480,Data> dataMap480) |
Message |
Message.setCommand(Message.Command command)
Command of the message, such as GET, PING, etc.
|
Message |
Message.setContentType(Message.Content contentType)
Convient method to set content type.
|
Message |
Message.setDataMap(Map<Number160,Data> dataMap) |
Message |
Message.setDataMap480(Map<Number480,Data> dataMap480) |
Message |
Message.setDataMapConvert(Map<Number480,Data> dataMap480) |
Message |
Message.setHashDataMap(Map<Number160,HashData> hashDataMap) |
Message |
Message.setInteger(int int_number) |
Message |
Message.setKey(Number160 key3) |
Message |
Message.setKeyKey(Number160 key1,
Number160 key2) |
Message |
Message.setKeyMap(Map<Number160,Number160> keyMap) |
Message |
Message.setKeys(Collection<Number160> keys) |
Message |
Message.setKeys480(Collection<Number480> keys480) |
Message |
Message.setKeysConvert(Collection<Number480> keys480) |
Message |
Message.setLength(long length)
Set payload length.
|
Message |
Message.setLong(long long_number) |
Message |
Message.setMessageId(int messageId)
For deserialization, we need to set the id
|
Message |
Message.setNeighbors(Collection<PeerAddress> neighbors) |
Message |
Message.setNeighbors(Collection<PeerAddress> neighbors,
int useAtMostNeighbors) |
Message |
Message.setPayload(org.jboss.netty.buffer.ChannelBuffer payload) |
Message |
Message.setPublicKey(PublicKey publicKey) |
Message |
Message.setPublicKeyAndSign(KeyPair keyPair) |
Message |
Message.setRecipient(PeerAddress recipient)
Set the ID of the recipient.
|
Message |
Message.setSender(PeerAddress sender)
The ID of the sender.
|
Message |
Message.setTrackerData(Collection<TrackerData> trackerData) |
Message |
Message.setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2) |
Message |
Message.setType(Message.Type type)
Set the message type.
|
Message |
Message.setVersion(int version)
For deserialization
|
Modifier and Type | Method and Description |
---|---|
static boolean |
MessageCodec.decodePayload(Message.Content content,
org.jboss.netty.buffer.ChannelBuffer buffer,
Message message)
Decodes the payload from a Netty buffer in a big switch
|
static boolean |
MessageCodec.decodeSignature(Signature signature,
Message message,
org.jboss.netty.buffer.ChannelBuffer buffer) |
static org.jboss.netty.buffer.ChannelBuffer |
MessageCodec.encodeHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
Message message)
The format looks as follows: 32bit p2p version - 32bit id - 4bit message
type - 4bit message command - 160bit sender id - 16bit tcp port - 16bit udp
port - 160bit recipient id - 16bit (4x4)content type - 8bit network
address information.
|
static void |
MessageCodec.encodePayload(Message message,
ProtocolChunkedInput input)
Encode payload
|
Constructor and Description |
---|
MessageID(Message message)
Creates a message Id.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultBroadcastHandler.receive(Message message) |
void |
BroadcastHandler.receive(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
ReplyHandler.createMessage(PeerAddress recipient,
Message.Command name,
Message.Type type) |
Message |
ReplyHandler.createResponseMessage(Message message,
Message.Type type) |
Message |
ReplyHandler.forwardMessage(Message message) |
abstract Message |
ReplyHandler.handleResponse(Message message,
boolean sign)
If the message is OK, that has been previously checked by the user using
checkMessage, a reply to the message is generated here.
|
Message |
DirectDataRPC.handleResponse(Message message,
boolean sign) |
Message |
TaskRPC.handleResponse(Message message,
boolean sign) |
Message |
TrackerRPC.handleResponse(Message message,
boolean sign) |
Message |
NeighborRPC.handleResponse(Message message,
boolean sign) |
Message |
PeerExchangeRPC.handleResponse(Message message,
boolean sign) |
Message |
StorageRPC.handleResponse(Message message,
boolean sign) |
Message |
QuitRPC.handleResponse(Message message,
boolean sign) |
Message |
HandshakeRPC.handleResponse(Message message,
boolean sign) |
Message |
BroadcastRPC.handleResponse(Message message,
boolean sign) |
Modifier and Type | Method and Description |
---|---|
Message |
ReplyHandler.createResponseMessage(Message message,
Message.Type type) |
Message |
ReplyHandler.forwardMessage(Message message) |
abstract Message |
ReplyHandler.handleResponse(Message message,
boolean sign)
If the message is OK, that has been previously checked by the user using
checkMessage, a reply to the message is generated here.
|
Message |
DirectDataRPC.handleResponse(Message message,
boolean sign) |
Message |
TaskRPC.handleResponse(Message message,
boolean sign) |
Message |
TrackerRPC.handleResponse(Message message,
boolean sign) |
Message |
NeighborRPC.handleResponse(Message message,
boolean sign) |
Message |
PeerExchangeRPC.handleResponse(Message message,
boolean sign) |
Message |
StorageRPC.handleResponse(Message message,
boolean sign) |
Message |
QuitRPC.handleResponse(Message message,
boolean sign) |
Message |
HandshakeRPC.handleResponse(Message message,
boolean sign) |
Message |
BroadcastRPC.handleResponse(Message message,
boolean sign) |
Constructor and Description |
---|
RequestHandlerTCP(K futureResponse,
PeerBean peerBean,
ConnectionBean connectionBean,
Message message) |
RequestHandlerUDP(K futureResponse,
PeerBean peerBean,
ConnectionBean connectionBean,
Message message) |
Copyright © 2013. All Rights Reserved.