alvinalexander.com | career | drupal | java | mac | mysql | perl | scala | uml | unix  

What this is

This file is included in the DevDaily.com "Java Source Code Warehouse" project. The intent of this project is to help you "Learn Java by Example" TM.

Other links

The source code

// $Header: /home/cvs/jakarta-jmeter/src/components/org/apache/jmeter/visualizers/GraphAccumModel.java,v 1.9 2004/02/13 01:48:46 sebb Exp $
/*
 * Copyright 2001-2004 The Apache Software Foundation.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * 
*/

package org.apache.jmeter.visualizers;

import java.io.Serializable;
import java.util.Collections;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;

import org.apache.jmeter.samplers.Clearable;
import org.apache.jmeter.samplers.SampleResult;
import org.apache.jorphan.logging.LoggingManager;
import org.apache.log.Logger;


/**
 * The model that collects the average of the set of pages to be sampled.
 *
 * @author     Khor Soon Hin
 * Created      2001/08/11
 * @version    $Revision: 1.9 $ Last updated: $Date: 2004/02/13 01:48:46 $
 */

public class GraphAccumModel implements Clearable, Serializable
{
    transient private static Logger log = LoggingManager.getLoggerForClass();

    protected String name;
    protected List samples;
    protected List listeners;

    protected long averageSum = 0;
    protected long variationSum = 0;
    protected long counter = 0;
    protected long previous = 0;
    protected long max = 1;
    protected boolean bigChange = false;
    protected SampleResult current;

    /**
     * Constructor.
     */
    public GraphAccumModel()
    {
        log.debug("Start : GraphAccumModel1");
        listeners = new LinkedList();
        samples = Collections.synchronizedList(new LinkedList());
        log.debug("End : GraphAccumModel1");
    }

    /**
     * Sets the Name attribute of the GraphModel object.
     *
     * @param  name  the new Name value
     */
    public void setName(String name)
    {
        this.name = name;
    }

    /**
     * Gets the SampleCount attribute of the GraphAccumModel object.
     *
     * @return    the SampleCount value
     */
    public int getSampleCount()
    {
        return samples.size();
    }

    /**
     * Gets the List attribute of the GraphAccumModel object.
     *
     * @return    the List value
     */
    public List getList()
    {
        return samples;
    }

    /**
     * Gets the Name attribute of the GraphModel object.
     *
     * @return    the Name value
     */
    public String getName()
    {
        return name;
    }

    /**
     * Gets the Max attribute of the GraphAccumModel object.
     *
     * @return    the Max value
     */
    public long getMax()
    {
        log.debug("getMax1 : Returning - " + max);
        return max;
    }

    /**
     * Adds a feature to the ModelListener attribute of the GraphAccumModel
     * object.
     *
     * @param  listener   the feature to be added to the GraphAccumListener
     *                    attribute.
     */
    public void addGraphAccumListener(GraphAccumListener listener)
    {
        listeners.add(listener);
    }

    /**
     * Clear the results.
     */
    public void clear()
    {
        log.debug("Start : clear1");
        samples.clear();
        max = 1;
        bigChange = true;
        this.fireDataChanged();
        log.debug("End : clear1");
    }

    /**
     * Add the new sample to the results.
     *
     * @param  res  sample containing the results
     */
    public void addNewSample(SampleResult res)
    {
        log.debug("Start : addNewSample1");
        // Set time to time taken to load this url without components (e.g.
        // images etc)
        long totalTime = res.getTime();

        if (log.isDebugEnabled())
        {
            log.debug("addNewSample1 : time - " + totalTime);
            log.debug("addNewSample1 : max - " + max);
        }
        if (totalTime > max)
        {
            bigChange = true;
            max = totalTime;
        }
        current = res;
        samples.add(res);
        log.debug("End : addNewSample1");
        fireDataChanged();
    }

    /**
     *  Depending on whether the graph needs to be rescale call the appropriate
     *  methods.
     */
    protected void fireDataChanged()
    {
        log.debug("Start : fireDataChanged1");
        Iterator iter = listeners.iterator();

        if (bigChange)
        {
            while (iter.hasNext())
            {
                ((GraphAccumListener) iter.next()).updateGui();
            }
            bigChange = false;
        }
        else
        {
            quickUpdate(current);
        }
        log.debug("End : fireDataChanged1");
    }

    /**
     * The sample to be added did not exceed the current set of samples so do
     * not need to rescale graph.
     */
    protected void quickUpdate(SampleResult s)
    {
        Iterator iter = listeners.iterator();
        {
            while (iter.hasNext())
            {
                ((GraphAccumListener) iter.next()).updateGui(s);
            }
        }
    }
}

... this post is sponsored by my books ...

#1 New Release!

FP Best Seller

 

new blog posts

 

Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.

A percentage of advertising revenue from
pages under the /java/jwarehouse URI on this website is
paid back to open source projects.