|
UNICORE Resource Broker NJS Plugin 1.5α1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.eurogrid.broker.server.AbstractBroker
Abstract broker that handles the identity delegation parts of brokering.
Field Summary | |
protected Map |
controlState
Mapping from tasks to their control state. |
protected boolean |
isInitialised
Whether the broker is initialised. |
protected String |
localVsiteName
The local Vsite name, used for checking for brokering loops. |
protected Logger |
logger
The master logger for the broker. |
Constructor Summary | |
AbstractBroker()
|
Method Summary | |
void |
apply(Control action,
CheckResources cr)
Apply the given action to the given check-resources operation. |
protected abstract void |
checkQoS(CheckQoS task,
IncarnatedUser incedUser,
User user,
byte[] extraInformation,
CheckQoS_Outcome outcome)
Perform a CheckQoS, producing an outcome. |
protected abstract void |
checkResources(CheckResources task,
IncarnatedUser incedUser,
User user,
byte[] extraInformation,
CheckResources_Outcome outcome)
Perform a CheckResources, producing an outcome. |
Logger |
getLogger()
Get the master logger for the broker. |
Logger |
getLogger(NamedPlugin np)
Create a logger instance that is specialised to running the given plugin module within this broker. |
QoSCheck |
getQoSCheckResource()
Return a QoSCheck object for advertising by the NJS. |
ResourceCheck |
getResourceCheckResource()
Return a ResourceCheck object for advertising by the NJS. |
Control |
getState(CheckResources cr)
Discover the control state of the given CheckResources task. |
void |
incarnateCheckQoS(CheckQoS task,
IncarnatedUser incedUser,
User user,
CheckQoS_Outcome outcome)
Incarnate a CheckQoS, producing an outcome. |
void |
incarnateCheckResources(CheckResources task,
IncarnatedUser incedUser,
User user,
CheckResources_Outcome outcome)
Incarnate a CheckResources, producing an outcome. |
protected abstract String |
initialise(Vsite vsite,
ResourceSet resources,
ResourceChecker.NJS njs,
Element configuration)
Initialise the core of the broker. |
void |
initialise(Vsite vsite,
ResourceSet resources,
ResourceChecker.NJS njs,
String initString)
Initialise ourselves |
protected void |
initialiseLogger()
|
protected abstract void |
logBannerMessage()
Write the main banner message to the log. |
String |
nextJobID()
Sequence value generator for use by brokers creating tasks. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.eurogrid.broker.server.NamedPlugin |
getFormalName, getName |
Methods inherited from interface com.fujitsu.arcon.njs.interfaces.ResourceChecker |
claim |
Field Detail |
protected Map controlState
protected boolean isInitialised
protected String localVsiteName
protected Logger logger
Constructor Detail |
public AbstractBroker()
Method Detail |
public void apply(Control action, CheckResources cr) throws Exception
apply
in interface ResourceChecker
Exception
protected abstract void checkQoS(CheckQoS task, IncarnatedUser incedUser, User user, byte[] extraInformation, CheckQoS_Outcome outcome) throws ResourceCheckerException
task
- the request to check resources that requires incarnationincedUser
- the incarnated user performing the checkuser
- the user performing the checkoutcome
- the incarnated user performing the check
ResourceCheckerException
protected abstract void checkResources(CheckResources task, IncarnatedUser incedUser, User user, byte[] extraInformation, CheckResources_Outcome outcome) throws ResourceCheckerException
task
- the request to check resources that requires incarnationincedUser
- the incarnated user performing the checkuser
- the User performing the checkoutcome
- the incarnated user performing the check
ResourceCheckerException
public Logger getLogger()
public Logger getLogger(NamedPlugin np)
public QoSCheck getQoSCheckResource()
getQoSCheckResource
in interface ResourceBroker
public ResourceCheck getResourceCheckResource()
getResourceCheckResource
in interface ResourceChecker
public Control getState(CheckResources cr)
CheckResources
task.
apply(Control,CheckResources)
public final void incarnateCheckQoS(CheckQoS task, IncarnatedUser incedUser, User user, CheckQoS_Outcome outcome) throws ResourceCheckerException
checkQoS(...)
that handles input validation and delegation.
incarnateCheckQoS
in interface ResourceBroker
task
- the request to check resources that requires incarnationincedUser
- the incarnated user performing the checkuser
- the User performing the checkoutcome
- the incarnated user performing the check
ResourceCheckerException
public final void incarnateCheckResources(CheckResources task, IncarnatedUser incedUser, User user, CheckResources_Outcome outcome) throws ResourceCheckerException
checkResources(...)
that handles input validation and delegation.
incarnateCheckResources
in interface ResourceChecker
task
- the request to check resources that requires incarnationincedUser
- the incarnated user performing the checkuser
- the User performing the checkoutcome
- the incarnated user performing the check
ResourceCheckerException
protected abstract String initialise(Vsite vsite, ResourceSet resources, ResourceChecker.NJS njs, Element configuration) throws ResourceCheckerException
vsite
- The Vsite where we are.resources
- The resources at this Vsite.njs
- The hosting NJS.configuration
- The root of the broker's XML/DOM configuration tree.
ResourceCheckerException
public final void initialise(Vsite vsite, ResourceSet resources, ResourceChecker.NJS njs, String initString) throws ResourceCheckerException
initialise
in interface ResourceChecker
vsite
- The Vsite where we are.resources
- The resources at this Vsite.njs
- The hosting NJS.initString
- The initialisation string (XML) from the IDB.
ResourceCheckerException
protected void initialiseLogger() throws ResourceCheckerException
ResourceCheckerException
protected abstract void logBannerMessage()
public String nextJobID()
|
UNICORE Resource Broker NJS Plugin 1.5α1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |