gov.bnl.star.offline.scheduler.policy
Class AssignmentByQueueMonitorPolicy

java.lang.Object
  gov.bnl.star.offline.scheduler.policy.PassivePolicy
      gov.bnl.star.offline.scheduler.policy.AssignmentByQueueMonitorPolicy

All Implemented Interfaces:

Policy

public class AssignmentByQueueMonitorPolicy
extends PassivePolicy

This policy takes the assignment from another policy, and assigns a queue depending on the result of the monitoring information.

Author:

Levente Hajdu

Field Summary

long	msTimeRefresh

Fields inherited from class gov.bnl.star.offline.scheduler.policy.PassivePolicy

genericQueueList, localQueueList, log, longQueue

Constructor Summary

AssignmentByQueueMonitorPolicy()

Method Summary

void	AssignmentByQueueMonitorPolicy()
void	assignQueues(Request request, java.util.List jobs)
java.util.List	FilterNonViableQueues(Job job, Request request)
double	getMaxLoadBeforeSwichOverToRunTime()
long	getMsTimeRefresh()
void	orderQueues()
int	QueueLoad(Queue queue)
void	setMaxLoadBeforeSwichOverToRunTime(double maxLoadBeforeSwichOverToRunTime)
void	setMsTimeRefresh(long msTimeRefresh)
void	setSOP()

Methods inherited from class gov.bnl.star.offline.scheduler.policy.PassivePolicy

addQueue, assignQueue, assignTargetMachine, ClearAllQueues, getBypassQueueTests, getClusterName, getLocalQueue, getLongQueue, getMinTimeLimitQueue, getNfsQueue, getXrootdPort, getXrootdRedirectorName, isRootdAvailable, isXrootdAvailable, QueueInfo, resize, setBypassQueueTests, setClusterName, setLocalQueue, setLongQueue, setMinTimeLimitQueue, setNfsQueue, setRootdAvailable, setXrootdAvailable, setXrootdPort, setXrootdRedirectorName

Methods inherited from class java.lang.Object

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

Field Detail

msTimeRefresh

public long msTimeRefresh

Constructor Detail

AssignmentByQueueMonitorPolicy

public AssignmentByQueueMonitorPolicy()

Method Detail

AssignmentByQueueMonitorPolicy

public void AssignmentByQueueMonitorPolicy()

assignQueues

public void assignQueues(Request request,
                         java.util.List jobs)

Overrides:

assignQueues in class PassivePolicy

FilterNonViableQueues

public java.util.List FilterNonViableQueues(Job job,
                                            Request request)

QueueLoad

public int QueueLoad(Queue queue)

orderQueues

public void orderQueues()

setSOP

public void setSOP()

setMaxLoadBeforeSwichOverToRunTime

public void setMaxLoadBeforeSwichOverToRunTime(double maxLoadBeforeSwichOverToRunTime)

getMaxLoadBeforeSwichOverToRunTime

public double getMaxLoadBeforeSwichOverToRunTime()

setMsTimeRefresh

public void setMsTimeRefresh(long msTimeRefresh)

getMsTimeRefresh

public long getMsTimeRefresh()