hu.mta.sztaki.lpds.cloud.simulator.energy
Class AggregatedEnergyMeter

java.lang.Object
  hu.mta.sztaki.lpds.cloud.simulator.Timed
      hu.mta.sztaki.lpds.cloud.simulator.energy.EnergyMeter
          hu.mta.sztaki.lpds.cloud.simulator.energy.AggregatedEnergyMeter

All Implemented Interfaces:

Comparable<Timed>

Direct Known Subclasses:

IaaSEnergyMeter, PhysicalMachineEnergyMeter

public class AggregatedEnergyMeter
extends EnergyMeter

Allows a group of energy meters to be operated simultaneously.

Author:

"Gabor Kecskemeti, Laboratory of Parallel and Distributed Systems, MTA SZTAKI (c) 2015"

Field Summary

List<EnergyMeter>

supervised The list of meters that supposed to be used together.

Fields inherited from class hu.mta.sztaki.lpds.cloud.simulator.energy.EnergyMeter

lastMetered

Constructor Summary

AggregatedEnergyMeter(List<EnergyMeter> toAggregate)
Constructs an aggregated meter with a list of energy meters to operate on top.

Method Summary

double	getTotalConsumption() Calculates the sum of total consumptions returned by each and every supervised meter
boolean	startMeter(long interval, boolean dropPriorReading) Dispatches start meter calls to all supervised meters.
void	stopMeter() Dispatches stop meter calls to all supervised meters
void	tick(long fires) This operation is ignored as the actual metering is done in the supervised meters, and the totalconsumption values are always calculated on demand.

Methods inherited from class hu.mta.sztaki.lpds.cloud.simulator.energy.EnergyMeter

getMeteringStarted, getMeteringStopped, increaseTotalConsumption, readjustMeter

Methods inherited from class hu.mta.sztaki.lpds.cloud.simulator.Timed

calcTimeJump, compareTo, fire, getFireCount, getFrequency, getNextEvent, getNextFire, isSubscribed, jumpTime, nextEventDistance, resetTimed, setBackPreference, simulateUntil, simulateUntilLastEvent, skipEventsTill, subscribe, toString, unsubscribe, updateFrequency

Methods inherited from class java.lang.Object

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

Field Detail

supervised

public final List<EnergyMeter> supervised

The list of meters that supposed to be used together. It is defined as public so aggregator users can freely update the supervised list any time they like

Constructor Detail

AggregatedEnergyMeter

public AggregatedEnergyMeter(List<EnergyMeter> toAggregate)

Constructs an aggregated meter with a list of energy meters to operate on top.

Parameters:

toAggregate - the list of energy meters to sopervise

Method Detail

startMeter

public boolean startMeter(long interval,
                          boolean dropPriorReading)

Dispatches start meter calls to all supervised meters. If even one of them fails, it immediately terminates those meters that were started before the failure.

Overrides:

startMeter in class EnergyMeter

Parameters:

interval - The meter refresh frequency.

dropPriorReading -

False: the totalConsumption values will accumulate from a previous metering session True: the totalconsumption values will start from 0 after the completion of this function.

Returns:

• False: if a metering session is already underway
• True: if the metering session was successfully initiated

stopMeter

public void stopMeter()

Dispatches stop meter calls to all supervised meters

Overrides:

stopMeter in class EnergyMeter

getTotalConsumption

public double getTotalConsumption()

Calculates the sum of total consumptions returned by each and every supervised meter

Overrides:

getTotalConsumption in class EnergyMeter

Returns:

the total consumption collected during the metering sessions

tick

public void tick(long fires)

This operation is ignored as the actual metering is done in the supervised meters, and the totalconsumption values are always calculated on demand.

Specified by:

tick in class Timed

Parameters:

fires - The particular time instance when the function was called. The time instance is passed so the tick functions will not need to call getFireCount() if they need to operate on the actual time.