cdef.java

httptunnel.jar httptunnel java 源码

/* ============================================================
 * JRobin : Pure java implementation of RRDTool's functionality
 * ============================================================
 *
 * Project Info:  http://www.jrobin.org
 * Project Lead:  Sasa Markovic ([e-mail])
 * 
 * Developers:    Sasa Markovic ([e-mail])
 *                Arne Vandamme ([e-mail])
 *
 * (C) Copyright 2003, by Sasa Markovic.
 *
 * This library is free software; you can redistribute it and/or modify it under the terms
 * of the GNU Lesser General Public License as published by the Free Software Foundation;
 * either version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License along with this
 * library; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307, USA.
 */
package net.jumperz.ext.org.jrobin.graph;

import java.util.HashMap;
import java.util.StringTokenizer;

import net.jumperz.ext.org.jrobin.core.RrdException;
import net.jumperz.ext.org.jrobin.core.XmlWriter;

/**
 * <p>Represents a 'calculated' datasource for a graph.  A calculated datasource is always based on a RPN
 * (Reverse Polar Notation) expression the algorithm to be used for calculating values.</p>
 * 
 * @author Arne Vandamme ([e-mail])
 */
class Cdef extends Source
{
	// ================================================================
	// -- Members
	// ================================================================
	private String[] strTokens;
		
	private double[] constants;
	private int[] dsIndices;
	private byte[] tokens;
	
	
	// ================================================================
	// -- Constructors
	// ================================================================
	/**
	 * Constructs a new simple Cdef object based on an empty RPN expression,.
	 *
	 * @param name Name of the datasource in the graph definition.
	 */
	Cdef( String name )
	{
		super( name );

		strTokens	= new String[0];
	}

	/**
	 * Constructs a new Cdef object holding a number of datapoints for a graph.
	 * A Cdef is always based on a RPN expression holding the calculation algorithm.
	 * @param name Name of the datasource in the graph definition.
	 * @param rpn Algorithm to use for value calculation in reverse polar notation (RPN) form.
	 */
	Cdef( String name, String rpn )
	{
		super(name);
		
		StringTokenizer st 	= new StringTokenizer(rpn, ",");
		int count 			= st.countTokens();
		strTokens 			= new String[count];
		
		for( int i = 0; st.hasMoreTokens(); i++ )
			strTokens[i] = st.nextToken().trim();	
	}


	// ================================================================
	// -- Protected methods
	// ================================================================
	/**
	 * Prepares the Cdef for faster value calculation by parsing the given RPN expression to 
	 * a better more efficient format. 
	 * @param sourceIndex Lookup table holding the name - index pairs for all datasources.
	 * @param numPoints Number of points used as graph resolution (size of the value table).
	 * @throws RrdException Thrown in case of a JRobin specific error.
	 */	
	void prepare( HashMap sourceIndex, int numPoints, int aggregatePoints ) throws RrdException
	{
		// Create values table of correct size
		values 					= new double[numPoints];
		this.aggregatePoints	= aggregatePoints;

		// Parse rpn expression for better performance
		String tkn;
		
		constants 	= new double[ strTokens.length ];
		dsIndices	= new int[ strTokens.length ];
		tokens		= new byte[ strTokens.length ];
		
		for (int i = 0; i < strTokens.length; i++)
		{
			tkn = strTokens[i];
			
			if ( isNumber(tkn) ) {
				tokens[i]		= RpnCalculator.TKN_CONSTANT;
				constants[i]	= Double.parseDouble(tkn);
			}
			else if ( sourceIndex.containsKey(tkn) ) {
				tokens[i]		= RpnCalculator.TKN_DATASOURCE;
				dsIndices[i]	= ( (Integer) sourceIndex.get(tkn) ).intValue();
			}
			else if ( tkn.equals("+") )
				tokens[i]		= RpnCalculator.TKN_PLUS;
			else if ( tkn.equals("-") )
				tokens[i]		= RpnCalculator.TKN_MINUS;
			else if ( tkn.equals("*") )
				tokens[i]		= RpnCalculator.TKN_MULTIPLY;
			else if ( tkn.equals("/") )
				tokens[i]		= RpnCalculator.TKN_DIVIDE;
			else if ( tkn.equals("%") )
				tokens[i]		= RpnCalculator.TKN_MOD;
			else if ( tkn.equals("SIN") )
				tokens[i]		= RpnCalculator.TKN_SIN;
			else if ( tkn.equals("COS") )
				tokens[i]		= RpnCalculator.TKN_COS;
			else if ( tkn.equals("LOG") )
				tokens[i]		= RpnCalculator.TKN_LOG;
			else if ( tkn.equals("EXP") )
				tokens[i]		= RpnCalculator.TKN_EXP;
			else if ( tkn.equals("FLOOR") )
				tokens[i]		= RpnCalculator.TKN_FLOOR;
			else if ( tkn.equals("CEIL") )
				tokens[i]		= RpnCalculator.TKN_CEIL;
			else if ( tkn.equals("ROUND") )
				tokens[i]		= RpnCalculator.TKN_ROUND;
			else if ( tkn.equals("POW") )
				tokens[i]		= RpnCalculator.TKN_POW;
			else if ( tkn.equals("ABS") )
				tokens[i]		= RpnCalculator.TKN_ABS;
			else if ( tkn.equals("SQRT") )
				tokens[i]		= RpnCalculator.TKN_SQRT;
			else if ( tkn.equals("RANDOM") )
				tokens[i]		= RpnCalculator.TKN_RANDOM;
			else if ( tkn.equals("LT") )
				tokens[i]		= RpnCalculator.TKN_LT;
			else if ( tkn.equals("LE") )
				tokens[i]		= RpnCalculator.TKN_LE;
			else if ( tkn.equals("GT") )
				tokens[i]		= RpnCalculator.TKN_GT;
			else if ( tkn.equals("GE") )
				tokens[i]		= RpnCalculator.TKN_GE;
			else if ( tkn.equals("EQ") )
				tokens[i]		= RpnCalculator.TKN_EQ;
			else if ( tkn.equals("IF") )
				tokens[i]		= RpnCalculator.TKN_IF;
			else if ( tkn.equals("MIN") )
				tokens[i]		= RpnCalculator.TKN_MIN;
			else if ( tkn.equals("MAX") )
				tokens[i]		= RpnCalculator.TKN_MAX;
			else if ( tkn.equals("LIMIT") )
				tokens[i]		= RpnCalculator.TKN_LIMIT;
			else if ( tkn.equals("DUP") )
				tokens[i]		= RpnCalculator.TKN_DUP;
			else if ( tkn.equals("EXC") )
				tokens[i]		= RpnCalculator.TKN_EXC;
			else if ( tkn.equals("POP") )
				tokens[i]		= RpnCalculator.TKN_POP;
			else if ( tkn.equals("UN") )
				tokens[i]		= RpnCalculator.TKN_UN;
			else if ( tkn.equals("UNKN") )
				tokens[i]		= RpnCalculator.TKN_UNKN;
			else if ( tkn.equals("NOW") )
				tokens[i]		= RpnCalculator.TKN_NOW;
			else if ( tkn.equals("TIME") )
				tokens[i]		= RpnCalculator.TKN_TIME;
			else if ( tkn.equals("PI") )
				tokens[i]		= RpnCalculator.TKN_PI;
			else if ( tkn.equals("E") )
				tokens[i]		= RpnCalculator.TKN_E;
			else if ( tkn.equals("AND") )
				tokens[i]		= RpnCalculator.TKN_AND;
			else if ( tkn.equals("OR") )
				tokens[i]		= RpnCalculator.TKN_OR;
			else if ( tkn.equals("XOR") )
				tokens[i]		= RpnCalculator.TKN_XOR;
			// Extra tokens for JRobin
			else if ( tkn.equals("SAMPLES") )
				tokens[i]		= RpnCalculator.TKN_SAMPLES;
			else if ( tkn.equals("STEP") )
				tokens[i]		= RpnCalculator.TKN_STEP;
			else
				throw new RrdException("Unknown token encountered: " + tkn);	
			
		}
	}

	/**
	 * Returns the level this Cdef would have in the calculation tree.  The level defines when
	 * the Cdef can be calculated.  The level depends on the number of Sdefs this Cdef is depending
	 * on, and their corresponding calculation levels.
	 *
	 * @param levels Array containing the previously calculated calculation levels.
	 * @return Level of this Sdef in the calculation tree.
	 */
	int calculateLevel( int[] levels )
	{
		int level 	= 0;

		for ( int i = 0; i < dsIndices.length; i++ )
			if ( levels[ dsIndices[i] ] > level )
				level = levels[ dsIndices[i] ];

		return level;
	}

	/**
	 * Sets the value of a specific datapoint for this Cdef.
	 * @param pos Position (index in the value table) of the new datapoint.
	 * @param timestamp Timestamp of the new datapoint in number of seconds.
	 * @param val Double value of the new datapoint.
	 */
	void set( int pos, long timestamp, double val )
	{
		super.set( pos, timestamp, val );
		values[pos] = val;
	}
	
	byte[] getTokens() {
		return tokens;
	}
	
	double[] getConstants() {
		return constants;
	}
	
	int[] getDsIndices() {
		return dsIndices;
	}
	
	String getRpnString()
	{
		StringBuffer tmpStr = new StringBuffer("");
		for (int i = 0; i < strTokens.length - 1; i++) {
			tmpStr.append( strTokens[i] );
			tmpStr.append( ',' );
		}
		if ( strTokens.length > 0 )
			tmpStr.append( strTokens[strTokens.length - 1] );
		
		return tmpStr.toString();
	}
	
	// ================================================================
	// -- Private methods
	// ================================================================
	/**
	 * Checks if a given string is a number.
	 * @param token String to check.
	 * @return True if the token is a number, false if not.
	 */	
	private boolean isNumber( String token ) 
	{
		try 
		{
			Double.parseDouble(token);
			
			return true;
		}
		catch (NumberFormatException nfe) {
			return false;
		}
	}

	void exportXml(XmlWriter xml) {
		xml.startTag("def");
		xml.writeTag("name", getName());
		xml.writeTag("rpn", getRpnString());
		xml.closeTag(); // def
	}
}