Class Manager

java.lang.Object
  extended by Manager
Direct Known Subclasses:
Emulator, Simulator

public abstract class Manager
extends java.lang.Object

 Abstract class defining generic routines for running network code under Fishnet
 


Field Summary
protected  CommandsParser parser
           
protected  java.io.BufferedReader reader
           
protected  SortedEventQueue sortedEvents
           
 
Constructor Summary
protected Manager(long time)
          Initialize Manager.
 
Method Summary
protected  void addEvent(long timeToOccur, java.lang.String methodName, java.lang.Object obj, java.lang.String[] paramTypes, java.lang.Object[] params)
           
 void addTimer(int nodeAddr, long deltaT, Callback callback)
          Adds a timer to be fired at deltaT milliseconds in the future
 void addTimerAt(int nodeAddr, long t, Callback callback)
          Adds a timer to be fired at time t
abstract  long now()
          Retrieve current time in milliseconds
protected  void packetDropped()
          Called upon when a packet is dropped due to buffer overflow
protected  void packetLost()
          Called upon when a packet is lost due to transmission error
protected  long readFishFile(long deferTill)
          Reads one line of the fish commands file and returns how long to delay further parsing if time command was found Call this function after now > 0
abstract  boolean sendNodeMsg(int nodeAddr, java.lang.String msg)
          Sends the msg to the the specified node
 boolean sendPkt(int from, int to, byte[] pkt)
          Send the pkt to the specified node
 void setFishnetFile(java.lang.String filename)
          Sets the fishnet file that commands should be read from
protected  void setParser(CommandsParser parser)
           
 void setTimescale(double timescale)
          Sets the amount to scale real time by.
abstract  void start()
          Starts the Manager.
 void stop()
          Stops Fishnet.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

sortedEvents

protected SortedEventQueue sortedEvents

parser

protected CommandsParser parser

reader

protected java.io.BufferedReader reader
Constructor Detail

Manager

protected Manager(long time)
Initialize Manager.

Parameters:
time - Starting time in microseconds
Method Detail

start

public abstract void start()
Starts the Manager. This runs in an infinite loop until network is stopped Instantiates nodes and gets them running


stop

public void stop()
Stops Fishnet. Normally this method should not return


setFishnetFile

public void setFishnetFile(java.lang.String filename)
                    throws java.io.FileNotFoundException
Sets the fishnet file that commands should be read from

Parameters:
filename - The name of the file that commands should be read from
Throws:
java.io.FileNotFoundException - If the named filed does not exist, is a directory rather than a regular file, or for some other reason cannot be opened for reading

sendPkt

public boolean sendPkt(int from,
                       int to,
                       byte[] pkt)
                throws java.lang.IllegalArgumentException
Send the pkt to the specified node

Parameters:
from - The node that is sending the packet
to - Int spefying the destination node
pkt - The packet to be sent, serialized to a byte array
Returns:
True if the packet was sent, false otherwise
Throws:
java.lang.IllegalArgumentException - If the arguments are invalid

packetDropped

protected void packetDropped()
Called upon when a packet is dropped due to buffer overflow


packetLost

protected void packetLost()
Called upon when a packet is lost due to transmission error


addTimerAt

public void addTimerAt(int nodeAddr,
                       long t,
                       Callback callback)
Adds a timer to be fired at time t

Parameters:
nodeAddr - Addr of node that is registering this timer
t - The time when the timer should fire. In milliseconds
callback - The callback to be invoked when the timer fires

addTimer

public void addTimer(int nodeAddr,
                     long deltaT,
                     Callback callback)
Adds a timer to be fired at deltaT milliseconds in the future

Parameters:
nodeAddr - Addr of node that is registering this timer
deltaT - The time interval after which the timer should fire. In milliseconds
callback - The callback to be invoked when the timer fires

now

public abstract long now()
Retrieve current time in milliseconds

Returns:
Current time in milliseconds

sendNodeMsg

public abstract boolean sendNodeMsg(int nodeAddr,
                                    java.lang.String msg)
Sends the msg to the the specified node

Parameters:
nodeAddr - Address of the node to whom the message should be sent
msg - The msg to send to the node
Returns:
True if msg sent, false if address is not valid

setTimescale

public void setTimescale(double timescale)
Sets the amount to scale real time by. Is only valid for simiulator

Parameters:
timescale - The amount to scale real time by

setParser

protected void setParser(CommandsParser parser)

readFishFile

protected long readFishFile(long deferTill)
Reads one line of the fish commands file and returns how long to delay further parsing if time command was found Call this function after now > 0

Parameters:
deferTill - Should be the value returned by this function. Can be initialized to 0 for first invocation
Returns:
How long (in microseconds) to defer further parsing till. -1 if reached eof. 0 if no delay

addEvent

protected void addEvent(long timeToOccur,
                        java.lang.String methodName,
                        java.lang.Object obj,
                        java.lang.String[] paramTypes,
                        java.lang.Object[] params)