net.powermatcher.peakshaving

Class PeakShavingConcentrator

java.lang.Object

net.powermatcher.core.BaseAgent

net.powermatcher.core.BaseAgentEndpoint

net.powermatcher.core.concentrator.Concentrator

net.powermatcher.peakshaving.PeakShavingConcentrator

All Implemented Interfaces:

Agent, AgentEndpoint, MatcherEndpoint, ObservableAgent, TransformingConcentrator

public class PeakShavingConcentrator
extends Concentrator
implements TransformingConcentrator

This class represents a PeakShavingConcentrator component where several instances can be created.

The PeakShavingConcentrator receives Bid from the agents and forwards this in an aggregate Bid up in the hierarchy to a PeakShavingConcentrator or to the Auctioneer. It will receive price updates from the Auctioneer and forward them to its connected agents. TODO: add PeakShavingConcentrator comment.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PeakShavingConcentrator.Config

Nested classes/interfaces inherited from class net.powermatcher.core.BaseAgentEndpoint

BaseAgentEndpoint.Connected

Nested classes/interfaces inherited from interface net.powermatcher.api.AgentEndpoint

AgentEndpoint.Status

Field Summary

Fields

Modifier and Type	Field and Description
protected double	allocatedFlow The allocated flow as calculated from the aggregated bidcurve
protected double	ceiling Maximum power level applied in 'peak shaving'
protected double	floor Minimum power level applied in 'peak shaving'
protected double	measuredFlow Measured flow as reported via the peak shaving interface

Fields inherited from class net.powermatcher.core.concentrator.Concentrator

config

Fields inherited from class net.powermatcher.core.BaseAgentEndpoint

NOT_CONNECTED

Fields inherited from class net.powermatcher.core.BaseAgent

context, LOGGER

Constructor Summary

Constructors

Constructor and Description
PeakShavingConcentrator()

Method Summary

Methods

Modifier and Type	Method and Description
void	activate(java.util.Map<java.lang.String,?> properties) OSGi calls this method to activate a managed service.
void	activate(PeakShavingConcentrator.Config config) Convenient activate method that takes a PeakShavingConcentrator.Config object.
void	deactivate() OSGi calls this method to deactivate a managed service.
protected double	getUncontrolledFlow()
void	setMeasuredFlow(javax.measure.Measurable<javax.measure.quantity.Power> measuredFlow) Sets the current measured flow for a transformer.
protected Bid	transformBid(Bid aggregatedBid) This method should be overridden when the bid that will be sent has to be changed.
protected Price	transformPrice(Price price, SentBidInformation info) This method should be overridden when the price that will be sent down has to be changed.

Methods inherited from class net.powermatcher.core.concentrator.Concentrator

activate, addObserver, agentEndpointDisconnected, connectToAgent, connectToMatcher, handleBidUpdate, handlePriceUpdate, matcherEndpointDisconnected, removeObserver, setContext

Methods inherited from class net.powermatcher.core.BaseAgentEndpoint

getAgentId, getDesiredParentId, getLastBidUpdate, getStatus, init, publishBid

Methods inherited from class net.powermatcher.core.BaseAgent

now, publishEvent

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.powermatcher.api.AgentEndpoint

connectToMatcher, getDesiredParentId, getStatus, handlePriceUpdate, matcherEndpointDisconnected

Methods inherited from interface net.powermatcher.api.MatcherEndpoint

agentEndpointDisconnected, connectToAgent, handleBidUpdate

Methods inherited from interface net.powermatcher.api.Agent

getAgentId, setContext

Field Detail

floor

protected double floor

Minimum power level applied in 'peak shaving'

ceiling

protected double ceiling

Maximum power level applied in 'peak shaving'

measuredFlow

protected volatile double measuredFlow

Measured flow as reported via the peak shaving interface

allocatedFlow

protected volatile double allocatedFlow

The allocated flow as calculated from the aggregated bidcurve

Constructor Detail

PeakShavingConcentrator

public PeakShavingConcentrator()

Method Detail

activate

public void activate(java.util.Map<java.lang.String,?> properties)

OSGi calls this method to activate a managed service.

Overrides:

activate in class Concentrator

Parameters:

properties - the configuration properties

activate

public void activate(PeakShavingConcentrator.Config config)

Convenient activate method that takes a PeakShavingConcentrator.Config object. This also makes subclassing easier.

Parameters:

config - The PeakShavingConcentrator.Config object that configures this concentrator

deactivate

public void deactivate()

OSGi calls this method to deactivate a managed service.

Overrides:

deactivate in class Concentrator

transformBid

protected Bid transformBid(Bid aggregatedBid)

Description copied from class: Concentrator

This method should be overridden when the bid that will be sent has to be changed.

Overrides:

transformBid in class Concentrator

Parameters:

aggregatedBid - The (input) aggregated bid as calculated normally (the sum of all the bids of the agents).

Returns:

The bid that will be sent to the matcher that is connected to this Concentrator.

transformPrice

protected Price transformPrice(Price price,
                   SentBidInformation info)

Description copied from class: Concentrator

This method should be overridden when the price that will be sent down has to be changed. This is called just before the price will be sent down to the connected agents.

Overrides:

transformPrice in class Concentrator

Parameters:

price - The input price update as received from the connected matcher.

info - The information about the bid that has been send

Returns:

The Price as it has to be sent to the connected agents.

getUncontrolledFlow

protected double getUncontrolledFlow()

Returns:

the difference between the measured flow and the allocation for the cluster. If either the measurement or the allocation is not available, this method will return Double.NaN.

setMeasuredFlow

public void setMeasuredFlow(javax.measure.Measurable<javax.measure.quantity.Power> measuredFlow)

Description copied from interface: TransformingConcentrator

Sets the current measured flow for a transformer.

Specified by:

setMeasuredFlow in interface TransformingConcentrator

Parameters:

measuredFlow - The current power flow.