ants.p2p.utils.addresses
Class InetAddressEngine

java.lang.Object
  extended by java.lang.Thread
      extended by 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