Package | Description |
---|---|
net.tomp2p.connection | |
net.tomp2p.rpc |
Modifier and Type | Method and Description |
---|---|
FutureChannel |
ChannelCreator.createTCPChannel(ReplyTimeoutHandler timeoutHandler,
RequestHandlerTCP<? extends BaseFuture> requestHandler,
int connectTimeoutMillis,
InetSocketAddress recipient)
Creates a TCP channel future.
|
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.
|
Modifier and Type | Method and Description |
---|---|
RequestHandlerTCP<FutureResponse> |
HandshakeRPC.pingTCP(PeerAddress remotePeer) |
RequestHandlerTCP<FutureResponse> |
DirectDataRPC.prepareSend(PeerAddress remotePeer,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw)
Prepares for sending to a remote peer.
|
Modifier and Type | Method and Description |
---|---|
FutureResponse |
SenderCacheStrategy.putIfAbsent(CacheKey cacheKey,
RequestHandlerTCP<FutureResponse> request,
ChannelCreator channelCreator) |
Copyright © 2013. All Rights Reserved.