IntersectExpression.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Sorting/IntersectExpression.h>

#include <fesa-core/Sorting/HomogeneousDevCol.h>

#include <string>


namespace fesa
{

bool IntersectExpression::match(SortingContext sc)
{

    std::string intersectExprCandidate = sc.formula_;

    typedef enum
    {
        initState, parenthesesRemovalState, expr1State, intersectState, expr2State, endState
    } automaton;

    automaton state = initState, newState = initState;

    std::string::size_type pos;

    while (state != endState)
    {

        switch (state)
        {

            case initState:
                newState = parenthesesRemovalState;
                break;

            case parenthesesRemovalState:
                pos = intersectExprCandidate.find("(");

                if (pos != 0)
                {
                    return false;
                    //          throw FesaBadConfig("FESA_FWK", -1, "SORTING/IntersectExpression::match(): no start parenthesis") ;
                }

                intersectExprCandidate.erase(0, 1);

                pos = intersectExprCandidate.rfind(")");
                if (pos != (intersectExprCandidate.length() - 1))
                {
                    return false;
                    //          throw FesaBadConfig("FESA_FWK", -1, "SORTING/IntersectExpression::match(): no end parenthesis") ;
                }

                intersectExprCandidate.erase(pos, 1);

                newState = expr1State;

                break;

            case expr1State:
            {
                pos = intersectExprCandidate.find("and");

                if ((pos == std::string::npos))
                    return false;

                std::string s1 = intersectExprCandidate.substr(0, pos);

                SortingContext aSc;
                aSc.formula_ = s1;
                aSc.className_ = sc.className_;

                pExpr1_ = SortingExpression::tryMatch(aSc);

                if (pExpr1_ == 0)
                {
                    return false;
                }

                intersectExprCandidate.erase(0, pos + 3);

                newState = intersectState;
                break;
            }

            case intersectState:
                newState = expr2State;
                break;

            case expr2State:
            {

                std::string s2 = intersectExprCandidate;

                SortingContext aSc;
                aSc.formula_ = s2;
                aSc.className_ = sc.className_;

                pExpr2_ = SortingExpression::tryMatch(aSc);

                if (pExpr2_ == 0)
                {
                    return false;
                }

                newState = endState;
                break;

            }

            case endState:
                break;

        }

        state = newState;

    }

    return true;

}

std::set<HomogeneousDevCol *> IntersectExpression::evaluate()
{

    std::set<HomogeneousDevCol *> resultDevCol;

    std::set<HomogeneousDevCol *> set1 = pExpr1_->evaluate();
    std::set<HomogeneousDevCol *> set2 = pExpr2_->evaluate();

    std::set<HomogeneousDevCol *>::const_iterator it1, it2;

    for (it1 = set1.begin(); it1 != set1.end(); it1++)
    {
        for (it2 = set2.begin(); it2 != set2.end(); it2++)
        {
            HomogeneousDevCol * pResult = new HomogeneousDevCol();
            HomogeneousDevCol c1 = *(*it1);
            HomogeneousDevCol c2 = *(*it2);
            *pResult = c1 ^ c2; // intersect homogeneous device collections
            if (pResult->getSize() > 0)
            {
                resultDevCol.insert(pResult);
            } // otherwise there's no point of inserting an empty device-set...
        }
    }

    return resultDevCol;
}

IntersectExpression::IntersectExpression():pExpr1_(0),pExpr2_(0){}

IntersectExpression::~IntersectExpression()
{
    if (pExpr1_ != NULL)
    {
        delete pExpr1_;
        pExpr1_ = NULL;
    }
    if (pExpr2_ != NULL)
    {
        delete pExpr2_;
        pExpr2_ = NULL;
    }
}

} // fesa