dans.network

Class Processor

java.lang.Object

dans.network.NetworkObject

dans.network.Processor

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable

public class Processor
extends NetworkObject

Author:

Dan

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	EVENT_ALGORITHM_ADDED
static int	EVENT_ALGORITHM_REMOVED
static int	EVENT_ALGORITHM_UPDATED
static int	EVENT_DISPLAY
static int	EVENT_MESSAGE_RECEIVED
static int	EVENT_MESSAGE_SENT
static int	EVENT_NEIGHBOUR_ADDED
static int	EVENT_NEIGHBOUR_REMOVE
static int	EVENT_PART_FAIL
static int	EVENT_SOURCE_ADDED
static int	EVENT_SOURCE_REMOVE

Fields inherited from class dans.network.NetworkObject

EVENT_ID_UPDATE, EVENT_SETTINGS_UPDATE, EVENT_STATS_UPDATE, EVENT_STATUS_UPDATE, settings, settingsLock, stats, statsLock, status, STATUS_ERROR, STATUS_FAILED, STATUS_NOTSTARTED, STATUS_PAUSED, STATUS_RUNNING, STATUS_TERMINATED, STATUS_WAITING, statusLock

Constructor Summary

Constructors

Constructor and Description
Processor(java.lang.String id)
Processor(java.lang.String id, Processor p)

Method Summary

Modifier and Type	Method and Description
void	addAlgorithm(int port, java.lang.String algorithm)
void	addAlgorithm(int port, java.lang.String algorithm, java.lang.Object caller)
void	addNeighbour(Link l, Processor p)
void	addNeighbour(Link l, Processor p, java.lang.Object caller)
void	addSource(Link l, Processor p)
void	addSource(Link l, Processor p, java.lang.Object caller)
void	algorithmTerminated(Algorithm a)
void	algorithmUpdateStatus(Algorithm a, java.lang.String status)
java.lang.String	checkTermStatus()
protected void	copyFrom(NetworkObject o)
void	destory()
void	displayEvent(java.lang.String text, int pos, java.lang.Object caller)
java.lang.Object[][]	dumpAlgorithms()
java.util.Collection<Algorithm>	getAlgorithmInstance()
double	getLinkBandwidth(NetworkState ns, java.lang.String linkID)
int	getLinkDelay(NetworkState ns, java.lang.String linkID)
java.lang.String	getLinkID(java.lang.String procID)
java.lang.String[]	getLinkIDs()
Link[]	getLinks(NetworkState ns)
java.awt.Point	getLocation()
java.lang.String	getNeighbourID(java.lang.String linkID)
java.lang.String[]	getNeighbourIDs()
Processor[]	getNeighbours()
MessageInQueue	getQueue(int port)
char	getShortType()
java.lang.String[]	getSourceIDs()
java.lang.String[]	getSourceLinkIDs()
Processor[]	getSources()
java.lang.String	getType()
boolean	hasAlgorithmSet()
boolean	hasLink(java.lang.String linkID)
boolean	hasNeighbour(java.lang.String procID)
boolean	initializeAlgorithms(NetworkState ns)
boolean	isRoot()
boolean	portInUse(int port)
void	receive(Link l, BackEndMessage bm)
void	removeAlgorithm(int port)
void	removeAlgorithm(int port, java.lang.Object caller)
void	removeNeighbour(Link l)
void	removeNeighbour(Link l, java.lang.Object caller)
void	removeSource(Link l)
void	removeSource(Link l, java.lang.Object caller)
boolean	send(NetworkState ns, BackEndMessage bm, java.lang.Object caller)
void	setDefaultSettings(NetworkState ns)
void	setDefaultStats(NetworkState ns)
void	setLocation(java.awt.Point p)
void	startAlgorithms()
void	updateAlgorithm(int port, java.lang.String algorithm)
void	updateAlgorithm(int port, java.lang.String algorithm, java.lang.Object caller)
void	updatePort(int oldPort, int newPort)
void	updatePort(int oldPort, int newPort, java.lang.Object caller)

Methods inherited from class dans.network.NetworkObject

addListener, addListener, doSpeedChange, dumpSettings, dumpStats, getID, getSetting, getStat, getStatus, incrementSetting, incrementSetting, incrementSetting, incrementSetting, incrementStat, incrementStat, incrementStat, incrementStat, notifyListeners, removeListener, resetForLoad, setID, setID, setSetting, setSetting, setStat, setStat, setStatus, setStatus, toLogID, toString

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_NEIGHBOUR_ADDED

public static final int EVENT_NEIGHBOUR_ADDED

See Also:

Constant Field Values

EVENT_NEIGHBOUR_REMOVE

public static final int EVENT_NEIGHBOUR_REMOVE

See Also:

Constant Field Values

EVENT_ALGORITHM_ADDED

public static final int EVENT_ALGORITHM_ADDED

See Also:

Constant Field Values

EVENT_ALGORITHM_REMOVED

public static final int EVENT_ALGORITHM_REMOVED

See Also:

Constant Field Values

EVENT_ALGORITHM_UPDATED

public static final int EVENT_ALGORITHM_UPDATED

See Also:

Constant Field Values

EVENT_SOURCE_REMOVE

public static final int EVENT_SOURCE_REMOVE

See Also:

Constant Field Values

EVENT_SOURCE_ADDED

public static final int EVENT_SOURCE_ADDED

See Also:

Constant Field Values

EVENT_MESSAGE_SENT

public static final int EVENT_MESSAGE_SENT

See Also:

Constant Field Values

EVENT_MESSAGE_RECEIVED

public static final int EVENT_MESSAGE_RECEIVED

See Also:

Constant Field Values

EVENT_DISPLAY

public static final int EVENT_DISPLAY

See Also:

Constant Field Values

EVENT_PART_FAIL

public static final int EVENT_PART_FAIL

See Also:

Constant Field Values

Constructor Detail

Processor

public Processor(java.lang.String id,
                 Processor p)

Processor

public Processor(java.lang.String id)

Method Detail

copyFrom

protected void copyFrom(NetworkObject o)

Overrides:

copyFrom in class NetworkObject

setDefaultSettings

public void setDefaultSettings(NetworkState ns)

Specified by:

setDefaultSettings in class NetworkObject

getSourceLinkIDs

public java.lang.String[] getSourceLinkIDs()

getSources

public Processor[] getSources()

getSourceIDs

public java.lang.String[] getSourceIDs()

getLinkIDs

public java.lang.String[] getLinkIDs()

getLinks

public Link[] getLinks(NetworkState ns)

getNeighbours

public Processor[] getNeighbours()

getNeighbourIDs

public java.lang.String[] getNeighbourIDs()

hasNeighbour

public boolean hasNeighbour(java.lang.String procID)

getLinkDelay

public int getLinkDelay(NetworkState ns,
                        java.lang.String linkID)

getLinkBandwidth

public double getLinkBandwidth(NetworkState ns,
                               java.lang.String linkID)

hasLink

public boolean hasLink(java.lang.String linkID)

getNeighbourID

public java.lang.String getNeighbourID(java.lang.String linkID)

getLinkID

public java.lang.String getLinkID(java.lang.String procID)

addNeighbour

public void addNeighbour(Link l,
                         Processor p)

addNeighbour

public void addNeighbour(Link l,
                         Processor p,
                         java.lang.Object caller)

addSource

public void addSource(Link l,
                      Processor p)

addSource

public void addSource(Link l,
                      Processor p,
                      java.lang.Object caller)

removeNeighbour

public void removeNeighbour(Link l)

removeNeighbour

public void removeNeighbour(Link l,
                            java.lang.Object caller)

removeSource

public void removeSource(Link l)

removeSource

public void removeSource(Link l,
                         java.lang.Object caller)

setDefaultStats

public void setDefaultStats(NetworkState ns)

Specified by:

setDefaultStats in class NetworkObject

getType

public java.lang.String getType()

Specified by:

getType in class NetworkObject

hasAlgorithmSet

public boolean hasAlgorithmSet()

addAlgorithm

public void addAlgorithm(int port,
                         java.lang.String algorithm)

addAlgorithm

public void addAlgorithm(int port,
                         java.lang.String algorithm,
                         java.lang.Object caller)

updateAlgorithm

public void updateAlgorithm(int port,
                            java.lang.String algorithm)

updateAlgorithm

public void updateAlgorithm(int port,
                            java.lang.String algorithm,
                            java.lang.Object caller)

removeAlgorithm

public void removeAlgorithm(int port)

removeAlgorithm

public void removeAlgorithm(int port,
                            java.lang.Object caller)

portInUse

public boolean portInUse(int port)

dumpAlgorithms

public java.lang.Object[][] dumpAlgorithms()

updatePort

public void updatePort(int oldPort,
                       int newPort)

updatePort

public void updatePort(int oldPort,
                       int newPort,
                       java.lang.Object caller)

receive

public void receive(Link l,
                    BackEndMessage bm)

getQueue

public MessageInQueue getQueue(int port)

initializeAlgorithms

public boolean initializeAlgorithms(NetworkState ns)

isRoot

public boolean isRoot()

startAlgorithms

public void startAlgorithms()

getAlgorithmInstance

public java.util.Collection<Algorithm> getAlgorithmInstance()

send

public boolean send(NetworkState ns,
                    BackEndMessage bm,
                    java.lang.Object caller)

algorithmUpdateStatus

public void algorithmUpdateStatus(Algorithm a,
                                  java.lang.String status)

algorithmTerminated

public void algorithmTerminated(Algorithm a)

displayEvent

public void displayEvent(java.lang.String text,
                         int pos,
                         java.lang.Object caller)

getShortType

public char getShortType()

Specified by:

getShortType in class NetworkObject

checkTermStatus

public java.lang.String checkTermStatus()

destory

public void destory()

Overrides:

destory in class NetworkObject

setLocation

public void setLocation(java.awt.Point p)

getLocation

public java.awt.Point getLocation()