Package org.apache.imperius.spl.core

Examples of org.apache.imperius.spl.core.DataCollector


    }

    public void initialize() throws SPLException {

        DataCollector dc = new JavaDataCollectorImpl();
        Actuator ac = new JavaActuatorImpl();
        _policyManager = new PolicyManagerImpl(dc, ac);

        // registering internal client
        InternalClient oInternalClientObj = new InternalClient(_policyManager);
View Full Code Here


   */

  private ArrayList filterTargetClassInstanceReferencesWithTargetExpression(List targetClassInstanceReferences , String className,String namespc) throws SPLException
  {
    logger.entering(sourceClass,Thread.currentThread().getName()+" "+ "filterTargetClassInstanceReferencesWithTargetExpression");
    DataCollector dc = DataCollectorFactory.getDataCollector();
    ArrayList filteredTargetClassInstanceReferences = new ArrayList();
    if(targetClassInstanceReferences!=null)
    {


      Iterator it=targetClassInstanceReferences.iterator();
      while(it.hasNext())
      {
        Object cop=(Object)it.next();
        //System.out.println("getSymbolsForInstance "+className+" "+ namespc+" "+ cop);
        Map map = dc.getSymbolsForInstance(className, namespc, cop);
        //System.out.println("map.size() "+map.size()+" "+map.toString());
        //symTab.populateInstanceValuesForCollect(className, className, cop, map);
        //NRJ
        symTab.populateInstanceValuesForInstance(className, className, cop, map);
        Boolean result = (Boolean)expressionForTarget.evaluate();
View Full Code Here

    logger = SPLLogger.getSPLLogger().getLogger();
//    auditLogger = SPLLogger.getSPLLogger().getAuditLogger();
//   
//    if(auditLogger.isLoggable(Level.FINE))
//      logger.fine(Thread.currentThread().getName()+" Initializing Policy Provider" );
    DataCollector dc = new CIMDataCollectorImpl(ch);

    Actuator ac = new CIMActuatorImpl(ch);

    _policyManager= new PolicyManagerImpl(dc,ac);
   
View Full Code Here

    }
    public Object evaluate(Object parentObject) throws SPLException
    {
        Object returnValue = null;
       
        DataCollector dc = DataCollectorFactory.getDataCollector();
        String qualifier = _symbolTable.getQualifierForClass(_classType);
        Map symbolsofInstance = dc.getSymbolsForInstance(_classType,
                qualifier,
                parentObject);
        Map instanceMap = new HashMap();
        instanceMap.put(_classType, parentObject);
        _symbolTable.populateInstanceValuesForInstance(_classType,
View Full Code Here

    SPLTreeParser tparse = new SPLTreeParser();
    tparse.setASTNodeClass("org.apache.imperius.spl.parser.compiler.ASTWithLineNumber");
    try
    {
      DataCollector dc = DataCollectorFactory.getDataCollector();
      SPLSymbolTable st = new SPLSymbolTable();
      SPLPolicy cp = tparse.splpolicy(t, dc, st);
      if(tparse.getErrorList() != null && tparse.getErrorList().size() > 0)
      {
        throw new SPLException(Messages.getString("SPL_POLICY_TREE_PARSING_EXCEPTION_MSG"));
View Full Code Here

    logger.entering(sourceClass,Thread.currentThread().getName()+" "+ "validateAssociation");

    //System.out.println("validateCollectFlavour1");

    boolean result = false;
    DataCollector dc = DataCollectorFactory.getDataCollector();
    result = dc.associationExists(sourceCIMClass, symTab.getDefaultQualifier(), resultclassName, assocName, roleName1, roleName2);
    if(!result)
    {

      logger.severe(Thread.currentThread().getName()+" "+"Invalid association " + " sourceClass :"+sourceCIMClass+" namespace :"+symTab.getDefaultQualifier()+ " resultclassName :" + resultclassName + " assocName :"+ assocName+ " roleName1 :" + roleName1 + " roleName2 :"+ roleName2);
View Full Code Here

    Object result = null;
    // evaluate the reference expression to obtain the source instance
    Object refExpressionResult = referenceExpression.evaluate();
    String referenceStr=refExpressionResult.toString();
    DataCollector dc = DataCollectorFactory.getDataCollector();

//    String refTypeName=dc.getReferenceTypeName(referenceStr);
    List targetClassInstanceReferences = null;


    // get instances of the targetclass that satisfy the association conditions
    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" refExpressionResult evaluateFlavour2 "+referenceStr);
    //System.out.println("targetClassInstanceReferences to dc :"+refExpressionResult+" "+symTab.getDefaultQualifier()+" "+targetClassName+" "+associationName+" "+sourceRole+" "+targetRole);
   
    targetClassInstanceReferences = dc.getAssociatedInstanceReferences(refExpressionResult,symTab.getDefaultQualifier(),targetClassName,associationName,sourceRole,targetRole);
    //System.out.println("targetClassInstanceReferences "+targetClassInstanceReferences.toString());
    if (logger.isLoggable(Level.FINE))
    logger.fine(Thread.currentThread().getName()+" got associated references");

//    targetClassInstance = dc.getAssociatedInstanceReferences(refTypeName, symTab.getDefaultQualifier(), targetClassName,associationName,sourceRole,targetRole, refExpressionResult);
    if (logger.isLoggable(Level.FINE))
    logger.fine(Thread.currentThread().getName()+" got associated instances");

    // filter the List based on the target filter expression
    //System.out.println("filteredTargetClassInstanceReferences to dc :"+targetClassInstanceReferences+" "+symTab.getDefaultQualifier()+" "+this.targetClassName);
   
    List filteredTargetClassInstanceReferences = filterTargetClassInstanceReferencesWithTargetExpression(targetClassInstanceReferences , this.targetClassName,this.symTab.getDefaultQualifier());
    //System.out.println("targetClassInstanceReferences "+filteredTargetClassInstanceReferences.toString());
   
    if (logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" got filtered references");

    ArrayList filteredTargetClassInstances = new ArrayList();

    Iterator filteredTargetClassInstanceReferencesIt=filteredTargetClassInstanceReferences.iterator();
    while(filteredTargetClassInstanceReferencesIt.hasNext())
    {
      Object ref=filteredTargetClassInstanceReferencesIt.next();
      Map instanceProperties=dc.getSymbolsForInstance(this.targetClassName,this.symTab.getDefaultQualifier(), ref);
      filteredTargetClassInstances.add(instanceProperties);
    }


View Full Code Here

    //evaluate the the first parameter to get the source instance
    Object refExpressionResult = referenceExpression.evaluate();
    String refExpressionStr=refExpressionResult.toString();
    //System.out.println("self = "+refExpressionResult);
    DataCollector dc = DataCollectorFactory.getDataCollector();
    //NRJ verify this works
//    String refTypeName = referenceExpression.getReferenceTypeName();
    //String refTypeName=dc.getReferenceTypeName(refExpressionStr);
    List targetClassInstanceReferences = null;

    // traverse association to get an array of target class instances. Each instance is a Map of key=values
    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" refExpressionResult evaluateFlavour1 "+refExpressionStr);

    targetClassInstanceReferences = dc.getAssociatedInstanceReferences((Object)refExpressionResult,symTab.getDefaultQualifier(),targetClassName,associationName,sourceRole,targetRole);
    //System.out.println("targetClassInstanceReferences size "+targetClassInstanceReferences.size());
    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" got associated references");

//    targetClassInstance = dc.getAssociatedInstanceReferences(refTypeName, symTab.getDefaultQualifier(), targetClassName,associationName,sourceRole,targetRole, refExpressionResult);
    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" got associated instances");

    // filter the List based on the target filter expression
    List filteredTargetClassInstanceReferences = filterTargetClassInstanceReferencesWithTargetExpression(targetClassInstanceReferences , this.targetClassName,this.symTab.getDefaultQualifier());
    //System.out.println("filteredTargetClassInstanceReferences size "+filteredTargetClassInstanceReferences.size());

    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" got filtered references");

    List filteredTargetClassInstances = new ArrayList();

    Iterator filteredTargetClassInstanceReferencesIt=filteredTargetClassInstanceReferences.iterator();
    while(filteredTargetClassInstanceReferencesIt.hasNext())
    {
      Object ref=filteredTargetClassInstanceReferencesIt.next();
      //System.out.println("filter passed : "+ref.toString());
      Map instanceProperties=dc.getSymbolsForInstance(this.targetClassName,this.symTab.getDefaultQualifier(), ref);
      filteredTargetClassInstances.add(instanceProperties);
    }

    if(logger.isLoggable(Level.FINE))
      logger.fine(Thread.currentThread().getName()+" got filtered instances");
View Full Code Here

  public void initialize(String url, String namespace, String username, String password) throws SPLException
  {
    logger.entering(sourceClass,Thread.currentThread().getName()+" "+"initialize");
   
    CIMClient a=getCIMClient(url, namespace, username, password);
    DataCollector dc = new CIMClientSideDataCollectorImpl(a);
    Actuator ac = new CIMClientSideActuatorImpl(a);
   
   
    _policyManager= new PolicyManagerImpl(dc,ac);
    _client=a;
View Full Code Here

TOP

Related Classes of org.apache.imperius.spl.core.DataCollector

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.