Uses of Class
net.tomp2p.connection.ChannelCreator

Packages that use ChannelCreator

net.tomp2p.connection
net.tomp2p.futures
net.tomp2p.p2p
net.tomp2p.rpc
net.tomp2p.task
net.tomp2p.utils

Uses of ChannelCreator in net.tomp2p.connection

Methods in net.tomp2p.connection that return ChannelCreator

ChannelCreator

PeerConnection.getChannelCreator()

Methods in net.tomp2p.connection with parameters of type ChannelCreator

void	ConnectionReservation.release(ChannelCreator channelCreator) Release a channelcreator.
void	ConnectionReservation.release(ChannelCreator channelCreator, int permits) Release a channelcreator.
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.

Constructors in net.tomp2p.connection with parameters of type ChannelCreator

PeerConnection(PeerAddress destination, ConnectionReservation connectionReservation, ChannelCreator channelCreator, int idleTCPMillis)

Uses of ChannelCreator in net.tomp2p.futures

Methods in net.tomp2p.futures that return ChannelCreator

ChannelCreator

FutureChannelCreator.getChannelCreator()

Methods in net.tomp2p.futures with parameters of type ChannelCreator

void	FutureChannelCreator.reserved(ChannelCreator channelCreator) Called if a channel creator could be created.

Uses of ChannelCreator in net.tomp2p.p2p

Methods in net.tomp2p.p2p with parameters of type ChannelCreator

FutureWrapper<FutureRouting>	DistributedRouting.bootstrap(Collection<PeerAddress> peerAddresses, int maxNoNewInfo, int maxFailures, int maxSuccess, int parallel, boolean forceTCP, boolean isForceRoutingOnlyToSelf, ChannelCreator cc) Bootstraps to the given peerAddresses, i.e.
FutureResponse	DistributedHashTable.Operation.create(ChannelCreator channelCreator, PeerAddress remotePeerAddress)
void	Peer.release(ChannelCreator channelCreator) Release a ChannelCreator.
FutureRouting	DistributedRouting.route(Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, Message.Type type, int maxDirectHits, int maxNoNewInfo, int maxFailures, int maxSuccess, int parallel, boolean forceTCP, ChannelCreator cc) Looks for a route to the given locationKey

Uses of ChannelCreator in net.tomp2p.rpc

Methods in net.tomp2p.rpc with parameters of type ChannelCreator

FutureResponse	StorageRPC.add(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Collection<Data> dataSet, boolean protectDomain, boolean signMessage, boolean list, ChannelCreator channelCreator, boolean forceUDP, SenderCacheStrategy senderCacheStrategy) Adds data on a remote peer.
FutureResponse	TrackerRPC.addToTracker(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, byte[] attachement, boolean signMessage, boolean primary, Set<Number160> knownPeers, ChannelCreator channelCreator, boolean forceUDP, boolean forceTCP)
FutureResponse	TrackerRPC.addToTracker(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, byte[] attachement, int offset, int legth, boolean signMessage, boolean primary, Set<Number160> knownPeers, ChannelCreator channelCreator, boolean forceUDP, boolean forceTCP)
FutureResponse	NeighborRPC.closeNeighbors(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, Message.Type type, ChannelCreator channelCreator, boolean forceTCP) Requests close neighbors from the remote peer.
FutureResponse	StorageRPC.compareAndPut(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Map<Number160,HashData> hashDataMap, FutureSuccessEvaluator futureSuccessEvaluator, boolean protectDomain, boolean protectEntry, boolean signMessage, boolean partialPut, ChannelCreator channelCreator, boolean forceUDP) Compares and puts data on a peer.
K	RequestHandlerTCP.fireAndForgetTCP(ChannelCreator channelCreator)
K	RequestHandlerTCP.fireAndForgetTCP(ChannelCreator channelCreator, int idleTCPMillis)
K	RequestHandlerUDP.fireAndForgetUDP(ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.fireTCP(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.fireUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	StorageRPC.get(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, SimpleBloomFilter<Number160> keyBloomFilter, SimpleBloomFilter<Number160> contentBloomFilter, boolean signMessage, boolean digest, boolean returnBloomFilter, boolean range, ChannelCreator channelCreator, boolean forceUDP) Get the data from a remote peer.
FutureResponse	TrackerRPC.getFromTracker(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, boolean expectAttachement, boolean signMessage, Set<Number160> knownPeers, ChannelCreator channelCreator)
FutureResponse	TrackerRPC.getFromTracker(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, boolean expectAttachement, boolean signMessage, Set<Number160> knownPeers, ChannelCreator channelCreator, boolean forceUDP, boolean forceTCP)
FutureResponse	PeerExchangeRPC.peerExchange(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, boolean isReplication, ChannelCreator channelCreator, boolean forceTCP) Peer exchange (PEX) information about other peers from the swarm, to not ask the primary trackers too often.
FutureResponse	HandshakeRPC.pingBroadcastUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingTCP(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingTCPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingTCPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingUDPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	HandshakeRPC.pingUDPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
FutureResponse	StorageRPC.put(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Map<Number160,Data> dataMap, boolean protectDomain, boolean protectEntry, boolean signMessage, ChannelCreator channelCreator, boolean forceUDP, SenderCacheStrategy senderCacheStrategy) Stores data on a remote peer.
FutureResponse	SenderCacheStrategy.putIfAbsent(CacheKey cacheKey, RequestHandlerTCP<FutureResponse> request, ChannelCreator channelCreator)
FutureResponse	StorageRPC.putIfAbsent(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Map<Number160,Data> dataMap, boolean protectDomain, boolean protectEntry, boolean signMessage, ChannelCreator channelCreator, boolean forceUDP, SenderCacheStrategy senderCacheStrategy) Stores data on a remote peer.
FutureResponse	QuitRPC.quit(PeerAddress remotePeer, ChannelCreator channelCreator, boolean forceTCP) Sends a message that indicates this peer is about to quit.
FutureResponse	StorageRPC.remove(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, boolean sendBackResults, boolean signMessage, ChannelCreator channelCreator, boolean forceUDP) Removes data from a peer.
FutureResponse	DirectDataRPC.send(PeerAddress remotePeer, org.jboss.netty.buffer.ChannelBuffer buffer, boolean raw, ChannelCreator channelCreator, boolean forceUDP)
FutureResponse	DirectDataRPC.send(PeerAddress remotePeer, org.jboss.netty.buffer.ChannelBuffer buffer, boolean raw, ChannelCreator channelCreator, int idleTCPMillis, boolean forceUDP) Send data directly to a peer.
FutureResponse	BroadcastRPC.send(PeerAddress remotePeer, Number160 messageKey, Map<Number160,Data> dataMap, ChannelCreator channelCreator, int idleTCPMillis, boolean forceUDP)
FutureResponse	BroadcastRPC.send(PeerAddress remotePeer, Number160 messageKey, Map<Number160,Data> dataMap, int hopCounter, ChannelCreator channelCreator, int idleTCPMillis, boolean forceUDP)
K	RequestHandlerUDP.sendBroadcastUDP(ChannelCreator channelCreator)
FutureResponse	TaskRPC.sendResult(PeerAddress remotePeer, ChannelCreator channelCreator, Number160 taskID, Map<Number160,Data> dataMap, KeyPair keyPair, boolean forceUDP, boolean sign)
FutureResponse	TaskRPC.sendTask(PeerAddress remotePeer, ChannelCreator channelCreator, Number160 taskID, Map<Number160,Data> dataMap, Worker mapper, KeyPair keyPair, boolean forceUDP, boolean sign) Sends a task to a remote peer.
K	RequestHandlerTCP.sendTCP(ChannelCreator channelCreator)
K	RequestHandlerTCP.sendTCP(ChannelCreator channelCreator, int idleTCPMillis)
K	RequestHandlerUDP.sendUDP(ChannelCreator channelCreator)
FutureResponse	TaskRPC.taskStatus(PeerAddress remotePeer, ChannelCreator channelCreator, Collection<Number160> taskIDs, boolean forceTCP)

Uses of ChannelCreator in net.tomp2p.task

Methods in net.tomp2p.task with parameters of type ChannelCreator

FutureAsyncTask

AsyncTask.submit(PeerAddress remotePeer, ChannelCreator channelCreator, Number160 taskId, Map<Number160,Data> dataMap, Worker mapper, boolean forceUDP, boolean sign)

Uses of ChannelCreator in net.tomp2p.utils

Methods in net.tomp2p.utils with parameters of type ChannelCreator

static void	Utils.addReleaseListener(BaseFuture baseFuture, ConnectionReservation connectionReservation, ChannelCreator cc, int nr)
static void	Utils.addReleaseListenerAll(BaseFuture baseFuture, ConnectionReservation connectionReservation, ChannelCreator channelCreator)