Package | Description |
---|---|
net.tomp2p.connection | |
net.tomp2p.examples | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.replication | |
net.tomp2p.task |
Modifier and Type | Method and Description |
---|---|
Peer |
PeerBean.getPeer() |
Modifier and Type | Method and Description |
---|---|
void |
PeerBean.setPeer(Peer peer) |
Modifier and Type | Method and Description |
---|---|
static Peer[] |
ExampleUtils.createAndAttachNodes(int nr,
int port)
Create peers with a port and attach it to the first peer in the array.
|
Modifier and Type | Method and Description |
---|---|
static void |
ExampleUtils.bootstrap(Peer[] peers)
Bootstraps peers to the first peer in the array.
|
static void |
ExampleUnQL.execute(Peer peer,
String query) |
Modifier and Type | Method and Description |
---|---|
Peer |
PeerMaker.getMasterPeer() |
Peer |
PeerMaker.makeAndListen() |
Modifier and Type | Method and Description |
---|---|
PeerMaker |
PeerMaker.setMasterPeer(Peer masterPeer) |
Constructor and Description |
---|
DefaultBroadcastHandler(Peer peer,
Random rnd) |
Modifier and Type | Field and Description |
---|---|
protected Peer |
DHTBuilder.peer |
protected Peer |
TrackerBuilder.peer |
Constructor and Description |
---|
AddBuilder(Peer peer,
Number160 locationKey) |
AddTrackerBuilder(Peer peer,
Number160 locationKey) |
BootstrapBuilder(Peer peer) |
BroadcastBuilder(Peer peer,
Number160 messageKey) |
DHTBuilder(Peer peer,
Number160 locationKey) |
DiscoverBuilder(Peer peer) |
GetBuilder(Peer peer,
Number160 locationKey) |
GetTrackerBuilder(Peer peer,
Number160 locationKey) |
ParallelRequestBuilder(Peer peer,
Number160 locationKey) |
PingBuilder(Peer peer) |
PutBuilder(Peer peer,
Number160 locationKey) |
RemoveBuilder(Peer peer,
Number160 locationKey) |
SendBuilder(Peer peer,
Number160 locationKey) |
SendDirectBuilder(Peer peer)
Deprecated.
|
SendDirectBuilder(Peer peer,
PeerAddress recipientAddress) |
SendDirectBuilder(Peer peer,
PeerConnection recipientConnection) |
SubmitBuilder(Peer peer,
Number160 locationKey,
Worker worker) |
TrackerBuilder(Peer peer,
Number160 locationKey) |
Constructor and Description |
---|
ReplicationExecutor(Peer peer)
Constructor for the default indirect replication.
|
TrackerStorageReplication(Peer peer,
PeerExchangeRPC peerExchangeRPC,
Map<BaseFuture,Long> pendingFutures,
TrackerStorage trackerStorage,
boolean forceTCP) |
Modifier and Type | Method and Description |
---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData) |
int |
TaskManager.submitTask(Peer peer,
Number160 taskId,
Worker mapper,
Map<Number160,Data> data,
PeerAddress senderAddress,
boolean sign) |
Copyright © 2013. All Rights Reserved.