|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.xtreemos.system.eventmachine.stage.AbstractStage
eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
eu.xtreemos.xosd.vops.VOPS
public class VOPS
VO Policy Service: this class provides basic functions which provide capabilities to manipulate with policy rules, obtain information about policies and execution of queries over policies.
Field Summary | |
---|---|
private java.lang.String |
delim
|
private boolean |
isGlobalVOPS
|
private boolean |
isUpToDate
|
private java.util.HashMap<eu.xtreemos.system.communication.net.CommunicationAddress,java.security.cert.X509Certificate> |
listOfRegisteredVOPS
|
private java.util.ArrayList<java.security.cert.X509Certificate> |
listOfVoAdminCerts
|
(package private) static org.apache.log4j.Logger |
logger
|
(package private) org.bouncycastle.openssl.PasswordFinder |
myPass
|
private SimplePDP |
pdp
Policy Decision Point |
private CVOPSConfig |
vopsConfig
|
Fields inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage |
---|
context, counter, curContext, sink |
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage |
---|
queue |
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage |
---|
handlerChain, handlerGroup, handlerThreads, name, running |
Constructor Summary | |
---|---|
VOPS()
|
Method Summary | |
---|---|
java.lang.Object |
addRule(java.lang.String ruleXML,
java.lang.String policyId)
Adds rule which is passed as XML string to the policy identified by policyId. |
java.lang.Object |
addXACMLRule(java.lang.String ruleXACML,
java.lang.String policyId)
Adds rule which is passed as XML string in XACML format to the policy identified by policyId. |
java.lang.Object |
createPolicy(java.lang.String policyID,
java.lang.String description)
A new policy file is created in policy storage using static PolicyFactory class. |
java.lang.Object |
evaluateRequest(java.lang.String xacmlRequest)
|
java.lang.Object |
generateRequest(java.lang.String jsdlQuery)
Generates XACML request based on provided jsdlQuery |
Policy |
getFilteredPolicy(java.security.cert.X509Certificate cert)
Deprecated. |
java.lang.Object |
getFilteredResources()
Return list of filtered addresses where execution is permitted. |
java.lang.String |
getHandledEventType()
|
java.lang.Object |
getResultFromResMngProcess(eu.xtreemos.xosd.vops.ReturnMessage retMsg)
Get answers from other nodes. |
java.lang.Object |
getResultsFromResMng(java.util.ArrayList<eu.xtreemos.system.communication.net.CommunicationAddress> list)
Callback function: catches results from resource manager. |
void |
handleEvent(java.lang.Object event)
|
void |
init()
Initialization of Policy Decision Point |
java.lang.Object |
listFilteredPolicy(java.lang.String xacmlRequest)
|
java.lang.Object |
listPolicies()
Returns policyIds and for which resource this policy applies to. |
java.lang.Object |
listPoliciesHandler(java.util.ArrayList<java.lang.String> alPolicies)
Catches global VOPS' reply of the policies and returns it to the client side. |
java.lang.Object |
listPolicy(java.lang.String policyId)
Lists specific policy with policyId. |
java.lang.Object |
listVoAdmins()
Lists a list of registered VO administrators. |
java.lang.Object |
policyEnforceRequestCertificateCatcher(java.util.Hashtable<eu.xtreemos.system.communication.net.CommunicationAddress,java.security.cert.X509Certificate> retFromService)
|
java.lang.Object |
policyEnforceRequestCertificateCatcherFailure(java.lang.Exception err)
Catches failures of CDAMng.getResourceCertificate call. |
java.lang.Object |
registerVoAdmin(java.security.cert.X509Certificate voAdminsCert)
Adds certificate passed as an argument into a list of trusted certificates (VO admins list). |
java.lang.Object |
registerVOPSToGlobalVOPS(eu.xtreemos.system.communication.net.CommunicationAddress address,
java.security.cert.X509Certificate certificate)
This registers VOPS to global VOPS service where decisions are made. |
java.lang.Object |
registerXOSDToVOPS(eu.xtreemos.system.communication.net.CommunicationAddress address,
java.security.cert.X509Certificate certificate)
Deprecated. This method is no longer used! |
java.lang.Object |
reloadVOPS()
Reloads all policies stored in policy storage. |
java.lang.Object |
removePolicy(java.lang.String policyId)
Policy with policyId will be removed from policy storage. |
java.lang.Object |
removeRuleFromPolicy(java.lang.String ruleId,
java.lang.String policyId)
Removes rule from policy with specified policyId. |
java.lang.Object |
unregisterVoAdmin(java.lang.Integer index)
Removes certificate with specified index from a list of trusted certificates. |
java.lang.Object |
verifyPolicyAEM(java.lang.Object xos_cert,
eu.xtreemos.xosd.resmng.data.ResourceMatching resources,
java.lang.String action)
|
java.lang.Object |
verifyPolicyCertRes(java.lang.Object xos_cert,
eu.xtreemos.xosd.resmng.data.ResourceMatching resources)
Method queries PDP for verification of the |
java.lang.Object |
verifyPolicyCertResHandle(eu.xtreemos.xosd.resmng.data.ResourceMatching returnedResMatching)
This callback gets filtered resources based on query which was submitted by verifyPolicyCertRes |
java.lang.Object |
writeBack()
Writes back policies from policy storage in PolicyFactory on to local disk. |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage |
---|
getContext, removeContext, SendException, SendReply, setSink |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage |
---|
dequeue, getSource |
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage |
---|
addHandler, addHandler, getName, getShortName, getThreadCount, processEvent, removeHandler, setThreadCount, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.lang.String delim
static final org.apache.log4j.Logger logger
private java.util.ArrayList<java.security.cert.X509Certificate> listOfVoAdminCerts
private boolean isGlobalVOPS
private java.util.HashMap<eu.xtreemos.system.communication.net.CommunicationAddress,java.security.cert.X509Certificate> listOfRegisteredVOPS
private CVOPSConfig vopsConfig
private boolean isUpToDate
private SimplePDP pdp
org.bouncycastle.openssl.PasswordFinder myPass
Constructor Detail |
---|
public VOPS()
Method Detail |
---|
public java.lang.Object registerVoAdmin(java.security.cert.X509Certificate voAdminsCert)
voAdminsCert
- certificate to add into a list of trusted certificates.
public java.lang.Object unregisterVoAdmin(java.lang.Integer index)
voAdminsCert
-
public java.lang.Object listVoAdmins()
public java.lang.Object verifyPolicyAEM(java.lang.Object xos_cert, eu.xtreemos.xosd.resmng.data.ResourceMatching resources, java.lang.String action)
public java.lang.Object policyEnforceRequestCertificateCatcherFailure(java.lang.Exception err)
err
-
public java.lang.Object policyEnforceRequestCertificateCatcher(java.util.Hashtable<eu.xtreemos.system.communication.net.CommunicationAddress,java.security.cert.X509Certificate> retFromService)
public java.lang.Object verifyPolicyCertRes(java.lang.Object xos_cert, eu.xtreemos.xosd.resmng.data.ResourceMatching resources)
xos_cert
- resources
-
public java.lang.Object verifyPolicyCertResHandle(eu.xtreemos.xosd.resmng.data.ResourceMatching returnedResMatching)
returnedResMatching
-
public java.lang.Object createPolicy(java.lang.String policyID, java.lang.String description)
policyID
- Id of new policy createddescription
- of new policy
public java.lang.Object removePolicy(java.lang.String policyId)
policyId
-
public java.lang.Object listPolicies()
public java.lang.Object listPoliciesHandler(java.util.ArrayList<java.lang.String> alPolicies)
alPolicies
-
public java.lang.Object listPolicy(java.lang.String policyId)
policyId
-
public java.lang.Object addRule(java.lang.String ruleXML, java.lang.String policyId)
ruleXML
- description of the rulepolicyId
- defines destination policy
public java.lang.Object addXACMLRule(java.lang.String ruleXACML, java.lang.String policyId) throws java.lang.Exception
ruleXACML
- XACML string presenting rule to be added to policypolicyId
- defines destination policy (to which policy this rule will be added)
java.lang.Exception
public java.lang.Object listFilteredPolicy(java.lang.String xacmlRequest)
public java.lang.Object evaluateRequest(java.lang.String xacmlRequest)
public java.lang.Object removeRuleFromPolicy(java.lang.String ruleId, java.lang.String policyId)
ruleId
- Rule which will be removed from policy.policyId
- policy from which this rule is removed.
public java.lang.Object writeBack()
public java.lang.Object reloadVOPS()
public java.lang.Object generateRequest(java.lang.String jsdlQuery)
jsdlQuery
- public java.lang.Object getResultsFromResMng(java.util.ArrayList<eu.xtreemos.system.communication.net.CommunicationAddress> list)
list
-
public java.lang.Object getResultFromResMngProcess(eu.xtreemos.xosd.vops.ReturnMessage retMsg)
retMsg
-
public java.lang.Object getFilteredResources()
public java.lang.Object registerXOSDToVOPS(eu.xtreemos.system.communication.net.CommunicationAddress address, java.security.cert.X509Certificate certificate)
address
- source addresscertificate
- which is used as resource info
public Policy getFilteredPolicy(java.security.cert.X509Certificate cert)
cert
- Certificate used to construct request.
public java.lang.Object registerVOPSToGlobalVOPS(eu.xtreemos.system.communication.net.CommunicationAddress address, java.security.cert.X509Certificate certificate)
address
- VOPS address to registercertificate
- of the VOPS
public void init()
init
in interface eu.xtreemos.system.eventmachine.stage.IStage
init
in class eu.xtreemos.system.eventmachine.stage.AbstractStage
public java.lang.String getHandledEventType()
getHandledEventType
in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
public void handleEvent(java.lang.Object event) throws java.lang.Exception
handleEvent
in interface eu.xtreemos.system.eventmachine.queue.IEventHandler
handleEvent
in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |