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

java.lang.Object
  extended by hu.mta.sztaki.lpds.cloud.simulator.Timed
      extended by hu.mta.sztaki.lpds.cloud.simulator.energy.MonitorConsumption
All Implemented Interfaces:
Comparable<Timed>

public class MonitorConsumption
extends Timed

This class is an initial framework to collect periodical reports on consumptions. In its current state it is too rigid and needs more customization. However, if extended further it would allow a single consumption monitor to be added to a particular resourcespreader, eliminating the need for multiple queries on the getTotalProcessed function.

Author:
"Gabor Kecskemeti, Distributed and Parallel Systems Group, University of Innsbruck (c) 2013"

Nested Class Summary
private  class MonitorConsumption.SpreadingRecord
           
 
Field Summary
private  double subDayProcessing
           
private  PriorityQueue<MonitorConsumption.SpreadingRecord> subDayRecords
           
private  double subHourProcessing
           
private  PriorityQueue<MonitorConsumption.SpreadingRecord> subHourRecords
           
private  double subSecondProcessing
           
(package private)  ResourceSpreader toMonitor
           
private  double totalProcessed
           
 
Constructor Summary
MonitorConsumption(ResourceSpreader toMonitor)
           
 
Method Summary
 double getSubDayProcessing()
           
 double getSubHourProcessing()
           
 double getSubSecondProcessing()
           
 void tick(long fires)
           
 
Methods inherited from class hu.mta.sztaki.lpds.cloud.simulator.Timed
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

toMonitor

final ResourceSpreader toMonitor

subHourRecords

private PriorityQueue<MonitorConsumption.SpreadingRecord> subHourRecords

subDayRecords

private PriorityQueue<MonitorConsumption.SpreadingRecord> subDayRecords

subHourProcessing

private double subHourProcessing

subDayProcessing

private double subDayProcessing

totalProcessed

private double totalProcessed

subSecondProcessing

private double subSecondProcessing
Constructor Detail

MonitorConsumption

public MonitorConsumption(ResourceSpreader toMonitor)
Method Detail

getSubDayProcessing

public double getSubDayProcessing()

getSubHourProcessing

public double getSubHourProcessing()

getSubSecondProcessing

public double getSubSecondProcessing()

tick

public void tick(long fires)
Specified by:
tick in class Timed


Copyright © 2012–2015 University of Innsbruck & MTA SZTAKI. All rights reserved.