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

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

All Implemented Interfaces:

Policy

public class DynamicConfigPolicy
extends PassivePolicy
implements Policy

Author:

lbhajdu

Field Summary

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

genericQueueList, localQueueList, log, longQueue

Constructor Summary

DynamicConfigPolicy()
Creates a new instance of DynamicConfigPolicy

Method Summary

java.util.List	assignTargetMachine(Request request) Processes a job requests, splitting into multiple processes and assigning the target machines.
java.lang.String	getService()
void	setService(java.lang.String service)

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

addQueue, assignQueue, assignQueues, 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

Constructor Detail

DynamicConfigPolicy

public DynamicConfigPolicy()

Creates a new instance of DynamicConfigPolicy

Method Detail

setService

public void setService(java.lang.String service)

getService

public java.lang.String getService()

assignTargetMachine

public java.util.List assignTargetMachine(Request request)

Description copied from class: PassivePolicy

Processes a job requests, splitting into multiple processes and assigning the target machines.

The step followed here are:

• Initializes the job ID
• Executes the catalog queries
• Changes the maxFilePerProcess to fit in the short queue if possible
• Using AssignmentStrategyFactory, retrieves the assignmentStrategies for each query, and assign the file to the different machines
• If the job had no input, just dispatch a job with no input
• If the job had input, split into processes according to the distribution
• If the the distribution is invalid (some user constraint weren't met) ask user permission to continue
• Assigns the correct queue depending on the estimated job length
• Saves the report

Most of these actions are done in a separate private method. Refer to those for more information.

Specified by:

assignTargetMachine in interface Policy

Overrides:

assignTargetMachine in class PassivePolicy

Parameters:

request - the job to be processed