edu.umass.cs.reconfiguration.reconfigurationutils

Class AggregateDemandProfiler

java.lang.Object

edu.umass.cs.reconfiguration.reconfigurationutils.AggregateDemandProfiler

public class AggregateDemandProfiler
extends java.lang.Object

Author:

V. Arun A utility class for maintaining demand profiles, specifically geo-distribution of demand in order to send it to reconfigurators.

Constructor Summary

Constructors

Constructor and Description
AggregateDemandProfiler()
AggregateDemandProfiler(ReconfigurableAppInfo nodeConfig)

Method Summary

Modifier and Type	Method and Description
AbstractDemandProfile	combine(AbstractDemandProfile update)
boolean	contains(java.lang.String name)
AbstractDemandProfile	pluckDemandProfile(java.lang.String name)
void	putIfEmpty(AbstractDemandProfile profile)
java.util.Set<java.lang.String>	reconfigure(java.lang.String name, java.util.Set<java.lang.String> curActives)
boolean	shouldSendDemandReport(Request request, java.net.InetAddress sender)
java.util.Set<java.lang.String>	testAndSetReconfigured(java.lang.String name, java.util.Set<java.lang.String> curActives, ReconfigurableAppInfo appInfo)
java.util.Set<AbstractDemandProfile>	trim() If aggregate size becomes more than DEFAULT_MAX_SIZE, this method will pluck DEFAULT_PLUCK_SIZE out so that an active replica can report it to reconfigurators.

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateDemandProfiler

public AggregateDemandProfiler(ReconfigurableAppInfo nodeConfig)

Parameters:

nodeConfig -

AggregateDemandProfiler

public AggregateDemandProfiler()

Method Detail

shouldSendDemandReport

public boolean shouldSendDemandReport(Request request,
                                      java.net.InetAddress sender)

Parameters:

request -

sender -

Returns:

AbstractDemandProfile after registering request.

contains

public boolean contains(java.lang.String name)

Parameters:

name -

Returns:

True if map contains name.

putIfEmpty

public void putIfEmpty(AbstractDemandProfile profile)

Parameters:

profile -

reconfigure

public java.util.Set<java.lang.String> reconfigure(java.lang.String name,
                                                   java.util.Set<java.lang.String> curActives)

Parameters:

name -

curActives -

Returns:

True if Reconfigurator should initiate a reconfiguration to the IP addresses returned.

testAndSetReconfigured

public java.util.Set<java.lang.String> testAndSetReconfigured(java.lang.String name,
                                                              java.util.Set<java.lang.String> curActives,
                                                              ReconfigurableAppInfo appInfo)

Parameters:

name -

curActives -

appInfo -

Returns:

List of IP addresses to which the replicas have been reconfigured. The testAndSet ensures atomicity.

trim

public java.util.Set<AbstractDemandProfile> trim()

If aggregate size becomes more than DEFAULT_MAX_SIZE, this method will pluck DEFAULT_PLUCK_SIZE out so that an active replica can report it to reconfigurators. This design allows an active replica to simply use transmission to reconfigurators as an alternative to persistently storing this information locally.

Returns:

Set of demand profiles to be shipped to reconfigurator(s).

pluckDemandProfile

public AbstractDemandProfile pluckDemandProfile(java.lang.String name)

Parameters:

name -

Returns:

Plucked demand profile.

combine

public AbstractDemandProfile combine(AbstractDemandProfile update)

Parameters:

update -

Returns:

Combined demand profile.