org.jppf.server.peer
Class PeerDiscoveryThread

java.lang.Object
  org.jppf.utils.ThreadSynchronization
      org.jppf.server.peer.PeerDiscoveryThread

All Implemented Interfaces:

Runnable

public class PeerDiscoveryThread
extends ThreadSynchronization
implements Runnable

Instances of this class discover peer drivers over the network.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.utils.ThreadSynchronization

stopped

Constructor Summary

PeerDiscoveryThread()
Default constructor.

Method Summary

void	addPeer(JPPFConnectionInformation info) Add a newly found peer.
void	removePeer(String name) Remove a disconnected peer.
void	run() Lookup server configurations from UDP multicasts.

Methods inherited from class org.jppf.utils.ThreadSynchronization

goToSleep, goToSleep, goToSleep, isStopped, setStopped, wakeUp

Methods inherited from class java.lang.Object

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

Constructor Detail

PeerDiscoveryThread

public PeerDiscoveryThread()

Default constructor.

Method Detail

run

public void run()

Lookup server configurations from UDP multicasts.

Specified by:

run in interface Runnable

See Also:

Runnable.run()

addPeer

public void addPeer(JPPFConnectionInformation info)

Add a newly found peer.

Parameters:

info - the peer's connection information.

removePeer

public void removePeer(String name)

Remove a disconnected peer.

Parameters:

name - the name of the peer to remove.