net.tomp2p.p2p
Class PeerMaker

java.lang.Object
  net.tomp2p.p2p.PeerMaker

public class PeerMaker
extends Object

Constructor Summary

PeerMaker(KeyPair keyPair)

PeerMaker(Number160 peerId)

Method Summary

int	getBagSize()
Bindings	getBindings()
BroadcastHandler	getBroadcastHandler()
int	getCacheSize()
int	getCacheTimeoutMillis()
ConnectionConfiguration	getConfiguration()
File	getFileMessageLogger()
KeyPair	getKeyPair()
int	getMaintenanceThreads()
MapAcceptHandler	getMapAcceptHandler()
Peer	getMasterPeer()
int	getMaxMessageSize()
int	getMaxNrBeforeExclude()
int	getP2PId()
Random	getRandom()
int	getReplicationRefreshMillis()
int	getReplicationThreads()
StorageGeneric	getStorage()
int	getTcpPort()
int	getUdpPort()
int[]	getWaitingTimeBetweenNodeMaintenenceSeconds()
int	getWorkerThreads()
boolean	isBehindFirewallPeerMap() Deprecated.
boolean	isEnableBroadcast()
boolean	isEnableDHT()
boolean	isEnableDirectDataRPC()
boolean	isEnableHandShakeRPC()
boolean	isEnableIndirectReplication()
boolean	isEnableMaintenance()
boolean	isEnableNeighborRPC()
boolean	isEnablePeerExchangeRPC()
boolean	isEnableQuitRPC()
boolean	isEnableRouting()
boolean	isEnableStorageRPC()
boolean	isEnableTask()
boolean	isEnableTaskRPC()
boolean	isEnableTracker()
boolean	isEnableTrackerRPC()
Peer	makeAndListen()
PeerMaker	setBagSize(int bagSize)
PeerMaker	setBehindFirewallPeerMap(boolean acceptFirstClassOnly) Deprecated.
PeerMaker	setBindings(Bindings bindings)
PeerMaker	setBroadcastHandler(BroadcastHandler broadcastHandler)
PeerMaker	setCacheSize(int cacheSize)
PeerMaker	setCacheTimeoutMillis(int cacheTimeoutMillis)
PeerMaker	setConfiguration(ConnectionConfiguration configuration)
PeerMaker	setEnableBroadcast(boolean enableBroadcast)
PeerMaker	setEnableDHT(boolean enableDHT)
PeerMaker	setEnableDirectDataRPC(boolean enableDirectDataRPC)
PeerMaker	setEnableHandShakeRPC(boolean enableHandShakeRPC)
PeerMaker	setEnableIndirectReplication(boolean enableIndirectReplication)
PeerMaker	setEnableMaintenance(boolean enableMaintenance)
PeerMaker	setEnableNeighborRPC(boolean enableNeighborRPC)
PeerMaker	setEnablePeerExchangeRPC(boolean enablePeerExchangeRPC)
PeerMaker	setEnableQuitRPC(boolean enableQuitRPC)
PeerMaker	setEnableRouting(boolean enableRouting)
PeerMaker	setEnableStorageRPC(boolean enableStorageRPC)
PeerMaker	setEnableTask(boolean enableTask)
PeerMaker	setEnableTaskRPC(boolean enableTaskRPC)
PeerMaker	setEnableTracker(boolean enableTracker)
PeerMaker	setEnableTrackerRPC(boolean enableTrackerRPC)
PeerMaker	setFileMessageLogger(File fileMessageLogger)
PeerMaker	setKeyPair(KeyPair keyPair)
PeerMaker	setMaintenanceThreads(int maintenanceThreads)
PeerMaker	setMapAcceptHandler(MapAcceptHandler mapAcceptHandler)
PeerMaker	setMasterPeer(Peer masterPeer)
PeerMaker	setMaxMessageSize(int maxMessageSize)
PeerMaker	setMaxNrBeforeExclude(int maxNrBeforeExclude)
PeerMaker	setP2PId(int p2pID)
PeerMaker	setPeerMapConfiguration(int bagSize, int cacheTimeoutMillis, int maxNrBeforeExclude, int[] waitingTimeBetweenNodeMaintenenceSeconds, int cacheSize, boolean isBehindFirewall) Deprecated.
PeerMaker	setPeerMapConfiguration(int bagSize, int cacheTimeoutMillis, int maxNrBeforeExclude, int[] waitingTimeBetweenNodeMaintenenceSeconds, int cacheSize, MapAcceptHandler mapAcceptHandler)
PeerMaker	setPorts(int port)
PeerMaker	setRandom(Random rnd)
PeerMaker	setReplicationRefreshMillis(int replicationRefreshMillis)
PeerMaker	setReplicationThreads(int replicationThreads)
PeerMaker	setStorage(StorageGeneric storage)
PeerMaker	setTcpPort(int tcpPort)
PeerMaker	setUdpPort(int udpPort)
PeerMaker	setWaitingTimeBetweenNodeMaintenenceSeconds(int[] waitingTimeBetweenNodeMaintenenceSeconds)
PeerMaker	setWorkerThreads(int workerThreads)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PeerMaker

public PeerMaker(Number160 peerId)

PeerMaker

public PeerMaker(KeyPair keyPair)

Method Detail

makeAndListen

public Peer makeAndListen()
                   throws IOException

Throws:

IOException

setPeerMapConfiguration

@Deprecated
public PeerMaker setPeerMapConfiguration(int bagSize,
                                                    int cacheTimeoutMillis,
                                                    int maxNrBeforeExclude,
                                                    int[] waitingTimeBetweenNodeMaintenenceSeconds,
                                                    int cacheSize,
                                                    boolean isBehindFirewall)

Deprecated.

setPeerMapConfiguration

public PeerMaker setPeerMapConfiguration(int bagSize,
                                         int cacheTimeoutMillis,
                                         int maxNrBeforeExclude,
                                         int[] waitingTimeBetweenNodeMaintenenceSeconds,
                                         int cacheSize,
                                         MapAcceptHandler mapAcceptHandler)

setP2PId

public PeerMaker setP2PId(int p2pID)

getP2PId

public int getP2PId()

setKeyPair

public PeerMaker setKeyPair(KeyPair keyPair)

getKeyPair

public KeyPair getKeyPair()

getWorkerThreads

public int getWorkerThreads()

setWorkerThreads

public PeerMaker setWorkerThreads(int workerThreads)

getMaintenanceThreads

public int getMaintenanceThreads()

setMaintenanceThreads

public PeerMaker setMaintenanceThreads(int maintenanceThreads)

getReplicationThreads

public int getReplicationThreads()

setReplicationThreads

public PeerMaker setReplicationThreads(int replicationThreads)

getReplicationRefreshMillis

public int getReplicationRefreshMillis()

setReplicationRefreshMillis

public PeerMaker setReplicationRefreshMillis(int replicationRefreshMillis)

getTcpPort

public int getTcpPort()

setTcpPort

public PeerMaker setTcpPort(int tcpPort)

getUdpPort

public int getUdpPort()

setUdpPort

public PeerMaker setUdpPort(int udpPort)

setPorts

public PeerMaker setPorts(int port)

getBindings

public Bindings getBindings()

setBindings

public PeerMaker setBindings(Bindings bindings)

getFileMessageLogger

public File getFileMessageLogger()

setFileMessageLogger

public PeerMaker setFileMessageLogger(File fileMessageLogger)

getConfiguration

public ConnectionConfiguration getConfiguration()

setConfiguration

public PeerMaker setConfiguration(ConnectionConfiguration configuration)

getStorage

public StorageGeneric getStorage()

setStorage

public PeerMaker setStorage(StorageGeneric storage)

getBagSize

public int getBagSize()

setBagSize

public PeerMaker setBagSize(int bagSize)

getCacheTimeoutMillis

public int getCacheTimeoutMillis()

setCacheTimeoutMillis

public PeerMaker setCacheTimeoutMillis(int cacheTimeoutMillis)

getMaxNrBeforeExclude

public int getMaxNrBeforeExclude()

setMaxNrBeforeExclude

public PeerMaker setMaxNrBeforeExclude(int maxNrBeforeExclude)

getWaitingTimeBetweenNodeMaintenenceSeconds

public int[] getWaitingTimeBetweenNodeMaintenenceSeconds()

setWaitingTimeBetweenNodeMaintenenceSeconds

public PeerMaker setWaitingTimeBetweenNodeMaintenenceSeconds(int[] waitingTimeBetweenNodeMaintenenceSeconds)

getCacheSize

public int getCacheSize()

setCacheSize

public PeerMaker setCacheSize(int cacheSize)

setBehindFirewallPeerMap

@Deprecated
public PeerMaker setBehindFirewallPeerMap(boolean acceptFirstClassOnly)

Deprecated.

isBehindFirewallPeerMap

@Deprecated
public boolean isBehindFirewallPeerMap()

Deprecated.

getMapAcceptHandler

public MapAcceptHandler getMapAcceptHandler()

setMapAcceptHandler

public PeerMaker setMapAcceptHandler(MapAcceptHandler mapAcceptHandler)

isEnableHandShakeRPC

public boolean isEnableHandShakeRPC()

setEnableHandShakeRPC

public PeerMaker setEnableHandShakeRPC(boolean enableHandShakeRPC)

isEnableStorageRPC

public boolean isEnableStorageRPC()

setEnableStorageRPC

public PeerMaker setEnableStorageRPC(boolean enableStorageRPC)

isEnableNeighborRPC

public boolean isEnableNeighborRPC()

setEnableNeighborRPC

public PeerMaker setEnableNeighborRPC(boolean enableNeighborRPC)

isEnableQuitRPC

public boolean isEnableQuitRPC()

setEnableQuitRPC

public PeerMaker setEnableQuitRPC(boolean enableQuitRPC)

isEnablePeerExchangeRPC

public boolean isEnablePeerExchangeRPC()

setEnablePeerExchangeRPC

public PeerMaker setEnablePeerExchangeRPC(boolean enablePeerExchangeRPC)

isEnableDirectDataRPC

public boolean isEnableDirectDataRPC()

setEnableDirectDataRPC

public PeerMaker setEnableDirectDataRPC(boolean enableDirectDataRPC)

isEnableTrackerRPC

public boolean isEnableTrackerRPC()

setEnableTrackerRPC

public PeerMaker setEnableTrackerRPC(boolean enableTrackerRPC)

isEnableTaskRPC

public boolean isEnableTaskRPC()

setEnableTaskRPC

public PeerMaker setEnableTaskRPC(boolean enableTaskRPC)

isEnableRouting

public boolean isEnableRouting()

setEnableRouting

public PeerMaker setEnableRouting(boolean enableRouting)

isEnableDHT

public boolean isEnableDHT()

setEnableDHT

public PeerMaker setEnableDHT(boolean enableDHT)

isEnableTracker

public boolean isEnableTracker()

setEnableTracker

public PeerMaker setEnableTracker(boolean enableTracker)

isEnableTask

public boolean isEnableTask()

setEnableTask

public PeerMaker setEnableTask(boolean enableTask)

isEnableMaintenance

public boolean isEnableMaintenance()

setEnableMaintenance

public PeerMaker setEnableMaintenance(boolean enableMaintenance)

getMasterPeer

public Peer getMasterPeer()

setMasterPeer

public PeerMaker setMasterPeer(Peer masterPeer)

getMaxMessageSize

public int getMaxMessageSize()

setMaxMessageSize

public PeerMaker setMaxMessageSize(int maxMessageSize)

isEnableIndirectReplication

public boolean isEnableIndirectReplication()

setEnableIndirectReplication

public PeerMaker setEnableIndirectReplication(boolean enableIndirectReplication)

getBroadcastHandler

public BroadcastHandler getBroadcastHandler()

setBroadcastHandler

public PeerMaker setBroadcastHandler(BroadcastHandler broadcastHandler)

isEnableBroadcast

public boolean isEnableBroadcast()

setEnableBroadcast

public PeerMaker setEnableBroadcast(boolean enableBroadcast)

getRandom

public Random getRandom()

setRandom

public PeerMaker setRandom(Random rnd)