|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object gov.bnl.star.offline.scheduler.policy.PassivePolicy
public class PassivePolicy
Decides how to split the job without triggering any resource redistribution. The passive policy doesn't trigger any file copy: it just collects information and does the best it can.
The policy will use copy selectors and file assignments to build the division. Refer to the documentation of those pieces for the details.
Overview of what the policy does
The policy basically solves all the queries, thus creating a big list of
files. Then, according to which machines the file reside, the files are divided
into different processes. At that point a new process is created.
How to configure the policy
There are few things how have to set in the policy to configure it. First of all, the queue names:
The last thing you will need to set, is whether rootd is available on the cluster. This will allow the policy to assign a job files that are on different local disks. This helps to satisfy the requirements, such as minFilesPerProcess when using files on local disk.
An optional setting is the clusterName, which will be assigned to all the jobs being created by this policy.
Field Summary | |
---|---|
java.util.List |
genericQueueList
|
java.util.List |
localQueueList
|
static org.apache.log4j.Logger |
log
|
protected java.lang.String |
longQueue
|
Constructor Summary | |
---|---|
PassivePolicy()
|
Method Summary | |
---|---|
void |
addQueue(Queue queue)
|
static void |
assignQueue(Queue queue,
Job job)
This member associates the job to the queue. |
void |
assignQueues(Request request,
java.util.List jobs)
|
java.util.List |
assignTargetMachine(Request request)
Processes a job requests, splitting into multiple processes and assigning the target machines. |
void |
ClearAllQueues()
|
boolean |
getBypassQueueTests()
|
java.lang.String |
getClusterName()
Getter for property clusterName. |
java.lang.String |
getLocalQueue()
|
java.lang.String |
getLongQueue()
|
int |
getMinTimeLimitQueue()
|
java.lang.String |
getNfsQueue()
|
static int |
getXrootdPort()
|
static java.lang.String |
getXrootdRedirectorName()
|
static boolean |
isRootdAvailable()
Tells the policy that rootd is available on the cluster. |
static boolean |
isXrootdAvailable()
|
java.lang.String |
QueueInfo(java.util.List localQueueList,
java.util.List genericQueueList)
|
java.lang.String |
resize(java.lang.String string,
int size)
|
void |
setBypassQueueTests(boolean bypassQueueTests)
|
void |
setClusterName(java.lang.String clusterName)
Sets the name of the cluster that will be assigned to all the jobs. |
void |
setLocalQueue(java.lang.String localQueue)
Changes the name of the local queue. |
void |
setLongQueue(java.lang.String longQueue)
Changes the name of the long queue. |
void |
setMinTimeLimitQueue(int minTimeLimit)
Sets the maximum duration of a job that will be sent to the short queue. |
void |
setNfsQueue(java.lang.String nfsQueue)
Changes the name of the NFS queue. |
static void |
setRootdAvailable(boolean rootdAvailable)
|
static void |
setXrootdAvailable(boolean xrootdAvailable)
|
static void |
setXrootdPort(int xrootdPort)
|
static void |
setXrootdRedirectorName(java.lang.String xrootdRedirectorName)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static org.apache.log4j.Logger log
protected java.lang.String longQueue
public java.util.List localQueueList
public java.util.List genericQueueList
Constructor Detail |
---|
public PassivePolicy()
Method Detail |
---|
public static void assignQueue(Queue queue, Job job)
public void assignQueues(Request request, java.util.List jobs)
public java.util.List assignTargetMachine(Request request)
The step followed here are:
assignTargetMachine
in interface Policy
request
- the job to be processedpublic void setNfsQueue(java.lang.String nfsQueue)
public java.lang.String getNfsQueue()
public void setLocalQueue(java.lang.String localQueue)
public java.lang.String getLocalQueue()
public void setLongQueue(java.lang.String longQueue)
public java.lang.String getLongQueue()
public void setMinTimeLimitQueue(int minTimeLimit)
public int getMinTimeLimitQueue()
public static boolean isRootdAvailable()
public static void setRootdAvailable(boolean rootdAvailable)
public static boolean isXrootdAvailable()
public static void setXrootdAvailable(boolean xrootdAvailable)
public static int getXrootdPort()
public static void setXrootdPort(int xrootdPort)
public static java.lang.String getXrootdRedirectorName()
public static void setXrootdRedirectorName(java.lang.String xrootdRedirectorName)
public java.lang.String getClusterName()
public void setClusterName(java.lang.String clusterName)
public void ClearAllQueues()
public java.lang.String resize(java.lang.String string, int size)
public java.lang.String QueueInfo(java.util.List localQueueList, java.util.List genericQueueList)
public void addQueue(Queue queue)
public void setBypassQueueTests(boolean bypassQueueTests)
public boolean getBypassQueueTests()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |