org.objectweb.proactive.benchmarks.timit.util
Class TimItReductor

java.lang.Object
  org.objectweb.proactive.benchmarks.timit.util.TimItReductor

All Implemented Interfaces:

java.io.Serializable

public class TimItReductor
extends java.lang.Object
implements java.io.Serializable

This class is an active object used by TimItManager to retrieve timers from all workers. It localized on Startable instance node

Author:

Brian Amedro, Vladimir Bodnartchouk

See Also:

Serialized Form

Field Summary

static int

TIMEOUT timeout (in seconds) when gatehering statistics from Timeds

Constructor Summary

TimItReductor()
Singleton pattern

Method Summary

void	clean() Invoked by TimIt beteween each run
long	getCurrentTimeMillis() Used by MigratableCounter as a network clock
EventDataBag	getEventDataBag()
BenchmarkStatistics	getStatistics() Invoked by TimItManager when Startable call finalizeStats()
static void	ready() Invoked by TimIt if an application timeout occur
void	receiveAll(EventDataBag eventDataBag, HierarchicalTimer receivedTimer, java.lang.String receivedInformation) This method will be called by a worker ie an observable object to reduce its vector of EventDatas.
void	receiveTimer(HierarchicalTimer receivedTimer) Invoked by Timed instances when finalizing
void	setGroupSize(int groupSize)
static void	stop() Invoked by TimIt if an application timeout occur
void	terminate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TIMEOUT

public static final int TIMEOUT

timeout (in seconds) when gatehering statistics from Timeds

See Also:

Constant Field Values

Constructor Detail

TimItReductor

public TimItReductor()

Singleton pattern

Method Detail

getCurrentTimeMillis

public long getCurrentTimeMillis()

Used by MigratableCounter as a network clock

Returns:

receiveTimer

public void receiveTimer(HierarchicalTimer receivedTimer)

Invoked by Timed instances when finalizing

Parameters:

receivedTimer -

setGroupSize

public void setGroupSize(int groupSize)

clean

public void clean()

Invoked by TimIt beteween each run

getStatistics

public BenchmarkStatistics getStatistics()

Invoked by TimItManager when Startable call finalizeStats()

Parameters:

groupSize - the size of the Timed group

Returns:

a BenchmarkStatistics

stop

public static void stop()

Invoked by TimIt if an application timeout occur

ready

public static void ready()

Invoked by TimIt if an application timeout occur

receiveAll

public void receiveAll(EventDataBag eventDataBag,
                       HierarchicalTimer receivedTimer,
                       java.lang.String receivedInformation)

This method will be called by a worker ie an observable object to reduce its vector of EventDatas. Important note : The order of each eventDataVector is preserved between workers.

getEventDataBag

public EventDataBag getEventDataBag()

Returns:

the EventDataBag of collapsed results

terminate

public void terminate()