ants.p2p.utils.addresses
Class InetAddressEngine

java.lang.Object
  java.lang.Thread
      ants.p2p.utils.addresses.InetAddressEngine

All Implemented Interfaces:

java.beans.PropertyChangeListener, java.lang.Runnable, java.util.EventListener

public class InetAddressEngine
extends java.lang.Thread
implements java.beans.PropertyChangeListener

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

static int	broadcastTimeToLive
static InetAddressEngine	instance
static java.io.File	peersFile
static int	peersToMemorize
static int	peersToSendback
static int	refreshRate
static java.io.File	trustedPeersFile

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

static void	addTrustedPeer(java.lang.String inetAddr, int port)
static boolean	contains(int[] indexes, int val)
static InetAddressEngine	getInstance()
static InetAddressEngine	getInstance(WarriorAnt owner)
static java.util.ArrayList	getPeersWithFreeSlots(boolean sendMyAddress)
static java.util.ArrayList	getRandomIMPeersWithFreeSlots(int howMany)
static java.util.ArrayList	getRandomPeersWithFreeSlots(int howMany, boolean sendMyAddress)
static java.util.ArrayList	getTrustedPeers()
void	propertyChange(java.beans.PropertyChangeEvent e)
static void	removeDeadPeer(ServerInfo s)
static void	removeTrustedPeer(ServerInfo sInfo)
void	run()
void	terminate()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

refreshRate

public static int refreshRate

peersToMemorize

public static int peersToMemorize

peersToSendback

public static int peersToSendback

broadcastTimeToLive

public static int broadcastTimeToLive

instance

public static InetAddressEngine instance

trustedPeersFile

public static java.io.File trustedPeersFile

peersFile

public static java.io.File peersFile

Method Detail

getInstance

public static InetAddressEngine getInstance(WarriorAnt owner)

getInstance

public static InetAddressEngine getInstance()

contains

public static boolean contains(int[] indexes,
                               int val)

getRandomIMPeersWithFreeSlots

public static java.util.ArrayList getRandomIMPeersWithFreeSlots(int howMany)

getRandomPeersWithFreeSlots

public static java.util.ArrayList getRandomPeersWithFreeSlots(int howMany,
                                                              boolean sendMyAddress)

getPeersWithFreeSlots

public static java.util.ArrayList getPeersWithFreeSlots(boolean sendMyAddress)

removeDeadPeer

public static void removeDeadPeer(ServerInfo s)

getTrustedPeers

public static java.util.ArrayList getTrustedPeers()

removeTrustedPeer

public static void removeTrustedPeer(ServerInfo sInfo)

addTrustedPeer

public static void addTrustedPeer(java.lang.String inetAddr,
                                  int port)

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

terminate

public void terminate()

propertyChange

public void propertyChange(java.beans.PropertyChangeEvent e)

Specified by:

propertyChange in interface java.beans.PropertyChangeListener