public Summariser() 
{
        super();
        synchronized (accumulators) {
            accumulators.clear();
            instanceCount=0;
        }
}

 public Summariser(String name) 
{
        this();
        setName(name);
}

Constructor for use during startup (intended for non-GUI use)

Parameters:

name - of summariser

 public  void sampleOccurred(SampleEvent e) 
{
        SampleResult s = e.getResult();
        long now = System.currentTimeMillis() / 1000;// in seconds
        RunningSample myDelta = null;
        RunningSample myTotal = null;
        boolean reportNow = false;
        /*
         * Have we reached the reporting boundary?
         * Need to allow for a margin of error, otherwise can miss the slot.
         * Also need to check we've not hit the window already
         */
        synchronized (myTotals) {
            if (s != null) {
                myTotals.delta.addSample(s);
            }
            if ((now  > myTotals.last + INTERVAL_WINDOW) && (now % INTERVAL < = INTERVAL_WINDOW)) {
                reportNow = true;
                // copy the data to minimise the synch time
                myDelta = new RunningSample(myTotals.delta);
                myTotals.moveDelta();
                myTotal = new RunningSample(myTotals.total);
                myTotals.last = now; // stop double-reporting
            }
        }
        if (reportNow) {
            String str;
            str = format(myName, myDelta, "+");
            if (TOLOG) {
                log.info(str);
            }
            if (TOOUT) {
                System.out.println(str);
            }
            // Only if we have updated them
            if (myTotal != null && myDelta != null &&myTotal.getNumSamples() != myDelta.getNumSamples()) {
                str = format(myName, myTotal, "=");
                if (TOLOG) {
                    log.info(str);
                }
                if (TOOUT) {
                    System.out.println(str);
                }
            }
        }
}

Accumulates the sample in two SampleResult objects - one for running totals, and the other for deltas.

 public  void sampleStarted(SampleEvent e) 
{
        // not used
}

 public  void sampleStopped(SampleEvent e) 
{
        // not used
}

 public  void testEnded() 
{
        testEnded("local");
}

 public  void testEnded(String host) 
{
        Object[] totals = null;
        synchronized (accumulators) {
            instanceCount--;
            if (instanceCount < = 0){
                totals = accumulators.entrySet().toArray();                
            }
        }
        if (totals == null) {// We're not done yet
            return;
        }
        for (int i=0; i< totals.length; i++) {
            Map.Entry me = (Map.Entry)totals[i];
            String str;
            String name = (String) me.getKey();
            Totals total = (Totals) me.getValue();
            // Only print final delta if there were some samples in the delta
            // and there has been at least one sample reported previously
            if (total.delta.getNumSamples()  > 0 && total.total.getNumSamples()  >  0) {
                str = format(name, total.delta, "+");
                if (TOLOG) {
                    log.info(str);
                }
                if (TOOUT) {
                    System.out.println(str);
                }
            }
            total.moveDelta();
            str = format(name, total.total, "=");
            if (TOLOG) {
                log.info(str);
            }
            if (TOOUT) {
                System.out.println(str);
            }
        }
}

 public  void testIterationStart(LoopIterationEvent event) 
{
        // not used
}

 public  void testStarted() 
{
        testStarted("local");
}

 public  void testStarted(String host) 
{
        synchronized (accumulators) {
            myName = getName();
            myTotals = (Totals) accumulators.get(myName);
            if (myTotals == null){
                myTotals = new Totals();
                accumulators.put(myName, myTotals);
            }
            instanceCount++;
        }
}