view flys-artifacts/src/main/java/de/intevation/flys/artifacts/transitions/ValueCompareTransition.java @ 5779:ebec12def170

Datacage: Add a pool of builders to make it multi threadable. XML DOM is not thread safe. Therefore the old implementation only allowed one thread to use the builder at a time. As the complexity of the configuration has increased over time this has become a bottleneck of the whole application because it took quiet some time to build a result. Furthermore the builder code path is visited very frequent. So many concurrent requests were piled up resulting in long waits for the users. To mitigate this problem a round robin pool of builders is used now. Each of the pooled builders has an independent copy of the XML template and can be run in parallel. The number of builders is determined by the system property 'flys.datacage.pool.size'. It defaults to 4.
author Sascha L. Teichmann <teichmann@intevation.de>
date Sun, 21 Apr 2013 12:48:09 +0200
parents eb5564662e19
children
line wrap: on
line source
package de.intevation.flys.artifacts.transitions;

import javax.xml.xpath.XPathConstants;

import org.apache.log4j.Logger;

import org.w3c.dom.Node;

import de.intevation.artifacts.Artifact;

import de.intevation.artifactdatabase.data.StateData;
import de.intevation.artifactdatabase.state.State;

import de.intevation.artifacts.common.utils.XMLUtils;

import de.intevation.flys.artifacts.FLYSArtifact;


/**
 * This transition compares data objects with a <i>equal</i> or <i>notequal</i>
 * operator.
 *
 * @author <a href="mailto:ingo.weinzierl@intevation.de">Ingo Weinzierl</a>
 */
public class ValueCompareTransition extends DefaultTransition {

    /** The logger that is used in this transition.*/
    private static Logger log = Logger.getLogger(ValueCompareTransition.class);


    /** XPath that points to the condition's operator.*/
    public static final String XPATH_OPERATOR = "condition/@operator";

    /** XPath that points to the condition's value.*/
    public static final String XPATH_VALUE    = "condition/@value";

    /** XPath that points  to the condition's dataname.*/
    public static final String XPATH_DATANAME = "condition/@data";

    /** The value of the 'equal' operator.*/
    public static final String OPERATOR_EQUAL = "equal";

    /** The value of the 'not equal' operator.*/
    public static final String OPERATOR_NOTEQUAL = "notequal";


    /** The operator.*/
    protected String operator;

    /** The value used for comparison.*/
    protected String value;

    /** The name of the data used for the comparison.*/
    protected String dataname;



    public ValueCompareTransition() {
    }


    public ValueCompareTransition(String from, String to) {
        super(from, to);
    }


    /** Setup member values from the document. */
    @Override
    public void init(Node config) {
        log.debug("ValueCompareTransition.init");

        String tmp = (String) XMLUtils.xpath(
            config,
            XPATH_OPERATOR,
            XPathConstants.STRING);
        operator = tmp.trim().toLowerCase();

        value = (String) XMLUtils.xpath(
            config,
            XPATH_VALUE,
            XPathConstants.STRING);

        dataname = (String) XMLUtils.xpath(
            config,
            XPATH_DATANAME,
            XPathConstants.STRING);
    }


    @Override
    public boolean isValid(Artifact artifact, State a, State b) {
        log.debug("ValueCompareTransition.isValid");

        FLYSArtifact flysArtifact = (FLYSArtifact) artifact;

        StateData dataObj = flysArtifact.getData(dataname);
        String    dataVal = dataObj != null ? (String) dataObj.getValue() : "";

        if (log.isDebugEnabled()) {
            log.debug("Compare settings:");
            log.debug("-- dataname: " + dataname);
            log.debug("-- operator: " + operator);
            log.debug("-- compare value: " + value);
            log.debug("-- state value: " + dataVal);
        }

        if (operator.equals(OPERATOR_EQUAL)) {
            return value.equals(dataVal);
        }
        else if (operator.equals(OPERATOR_NOTEQUAL)) {
            return !(value.equals(dataVal));
        }

        log.error("Wrong operator set! No comparison takes place.");

        return false;
    }
}
// vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

http://dive4elements.wald.intevation.org