mapping
Class LPAS_DG_MS

java.lang.Object
  extended by mapping.MappingScheme
      extended by mapping.LPAS_DG_MS

public class LPAS_DG_MS
extends MappingScheme

This is the implementation of the LPAS_DG scheduling policy.

Author:
Majd Kokaly

Constructor Summary
LPAS_DG_MS(Mapper mapper)
           
 
Method Summary
 JobsQueue[] getClassesQueues()
           
 DeltaStar getDeltaStar()
           
 LPAS_DG_MS_SOLVING_TICKER getTicker()
           
 void handleJobTimeOut(long jobID)
          Resubmit timed out jobs.
 void initQueues()
           
 void printQueues()
           
 void serverIsDown(int serverID)
          The LP allocation should be resolved when server changes its availability.
 void serverIsUp(int serverID)
          The LP allocation should be resolved when server changes its availability.
 void setClassesQueues(JobsQueue[] classesQueues)
           
 void setDeltaStar(DeltaStar deltaStar)
           
 void startMappingScheme()
          The LP allocation is solved and other data members are initialized plus all the threads are started in this method.
 void stopMappingScheme()
          The threads are stopped.
 
Methods inherited from class mapping.MappingScheme
getDescription, getMapper, setDescription, setMapper
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LPAS_DG_MS

public LPAS_DG_MS(Mapper mapper)
Method Detail

getClassesQueues

public JobsQueue[] getClassesQueues()

setClassesQueues

public void setClassesQueues(JobsQueue[] classesQueues)

getDeltaStar

public DeltaStar getDeltaStar()

setDeltaStar

public void setDeltaStar(DeltaStar deltaStar)

getTicker

public LPAS_DG_MS_SOLVING_TICKER getTicker()

startMappingScheme

public void startMappingScheme()
The LP allocation is solved and other data members are initialized plus all the threads are started in this method.

Specified by:
startMappingScheme in class MappingScheme
See Also:
MappingScheme.startMappingScheme()

stopMappingScheme

public void stopMappingScheme()
The threads are stopped.

Specified by:
stopMappingScheme in class MappingScheme
See Also:
MappingScheme.stopMappingScheme()

handleJobTimeOut

public void handleJobTimeOut(long jobID)
Resubmit timed out jobs.

Specified by:
handleJobTimeOut in class MappingScheme
See Also:
MappingScheme.handleJobTimeOut(long)

serverIsDown

public void serverIsDown(int serverID)
The LP allocation should be resolved when server changes its availability. That is what this method does.

Specified by:
serverIsDown in class MappingScheme
Parameters:
serverID - the serverID of the server that became unavailable
See Also:
MappingScheme.serverIsDown(int)

serverIsUp

public void serverIsUp(int serverID)
The LP allocation should be resolved when server changes its availability. That is what this method does.

Specified by:
serverIsUp in class MappingScheme
Parameters:
serverID - the serverID of the server that became unavailable
See Also:
MappingScheme.serverIsUp(int)

printQueues

public void printQueues()

initQueues

public void initQueues()