uk.ac.soton.itinnovation.grid.service.data
Class DataStagerManagerImpl

java.lang.Object
  uk.ac.soton.itinnovation.grid.service.data.DataStagerManagerImpl

All Implemented Interfaces:

Comparable<StorableInStateRepository>, StorableInStateRepository, ProxyHelpers, DataStagerManager

public class DataStagerManagerImpl
extends Object
implements DataStagerManager, ProxyHelpers

Default implementation of DataStagerManager

Author:

ds

Field Summary

Fields inherited from interface uk.ac.soton.itinnovation.grid.comms.data.DataStagerManager

PROXY_IFACE

Constructor Summary

DataStagerManagerImpl()

Method Summary

int	compareTo(StorableInStateRepository o)
void	dataStagerAddCumulativeUsageReport(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR, Metric metric, double value) Called when a data stager generates a cumulative usage report such as an update in the amount of data transfer used.
void	dataStagerContinueActivity(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR, Constraint[] constraints) Called when a data stager makes a continueActivity request.
void	dataStagerInstantaneousUsageChanged(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR, Metric metric) Called when a data stager generates an instantaneous usage report.
void	dataStagerStartActivity(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR, Constraint[] constraints, UsageReport[] usageReports) Called when a data stager makes a startActivity request.
String	getDescription() Returns a textual description of the object.
org.apache.axis.message.addressing.EndpointReferenceType	getEndpointRef() Return an EndpointReferenceType for this conversation.
URL	getURL() Returns the globally unique identifier.
<T> T	initProxyHelpers(HelperProxyFactory helperProxyFactory, org.apache.axis.message.addressing.EndpointReferenceType EPR, Class<T> iface) Initialises a new manager.
void	setDescription(String description) Change the textual description, as returned by getDescription.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataStagerManagerImpl

public DataStagerManagerImpl()

Method Detail

initProxyHelpers

public <T> T initProxyHelpers(HelperProxyFactory helperProxyFactory,
                              org.apache.axis.message.addressing.EndpointReferenceType EPR,
                              Class<T> iface)

Initialises a new manager. This should not be called directly - a HelperProxyFactory should be used to construct this class.

Specified by:

initProxyHelpers in interface ProxyHelpers

Parameters:

EPR - The EPR of a resource that "contains" the data stager.

helperProxyFactory - the factory creating the helper

iface - the interface requested by the caller of ProxyFactory.createProxy(org.apache.axis.message.addressing.EndpointReferenceType, java.lang.Class)

Returns:

the new proxy

dataStagerAddCumulativeUsageReport

public void dataStagerAddCumulativeUsageReport(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR,
                                               Metric metric,
                                               double value)

Description copied from interface: DataStagerManager

Called when a data stager generates a cumulative usage report such as an update in the amount of data transfer used.

Specified by:

dataStagerAddCumulativeUsageReport in interface DataStagerManager

Parameters:

stagerEPR - The EPR of the data stager generating the usage report

metric - The metric type of the resource being used

value - The cumulative increase in use of the metric

dataStagerContinueActivity

public void dataStagerContinueActivity(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR,
                                       Constraint[] constraints)
                                throws RemoteException

Description copied from interface: DataStagerManager

Called when a data stager makes a continueActivity request. This would usually be called on the SLA service.

Specified by:

dataStagerContinueActivity in interface DataStagerManager

Parameters:

stagerEPR - The EPR of the data stager making the request

constraints - An array of constraints that must be satisfied.

Throws:

RemoteException

dataStagerInstantaneousUsageChanged

public void dataStagerInstantaneousUsageChanged(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR,
                                                Metric metric)
                                         throws RemoteException

Description copied from interface: DataStagerManager

Called when a data stager generates an instantaneous usage report. This method does not include a value parameter as the implementation is supposed to total up the combined usage of this metric from all data stagers and send a single usage report.

Specified by:

dataStagerInstantaneousUsageChanged in interface DataStagerManager

Parameters:

stagerEPR - The EPR of the data stager generating the usage report

metric - The metric type of the resource being used

Throws:

RemoteException

dataStagerStartActivity

public void dataStagerStartActivity(org.apache.axis.message.addressing.EndpointReferenceType stagerEPR,
                                    Constraint[] constraints,
                                    UsageReport[] usageReports)

Description copied from interface: DataStagerManager

Called when a data stager makes a startActivity request. This would usually be called on the SLA service.

Specified by:

dataStagerStartActivity in interface DataStagerManager

Parameters:

stagerEPR - The EPR of the data stager making the request

constraints - An array of constraints that must be satisfied if the stager is to be created successfully.

usageReports - An array of initial usage reports.

getDescription

public String getDescription()

Description copied from interface: StorableInStateRepository

Returns a textual description of the object. This can be presented to the user when choosing from a list, for example.

Specified by:

getDescription in interface StorableInStateRepository

getEndpointRef

public org.apache.axis.message.addressing.EndpointReferenceType getEndpointRef()

Description copied from interface: StorableInStateRepository

Return an EndpointReferenceType for this conversation. This contains both the endpoint address of the service, and the resource itself.

Specified by:

getEndpointRef in interface StorableInStateRepository

getURL

public URL getURL()

Description copied from interface: StorableInStateRepository

Returns the globally unique identifier. No two distinct objects may have the same URL, even if they have different types.

Specified by:

getURL in interface StorableInStateRepository

setDescription

public void setDescription(String description)

Description copied from interface: StorableInStateRepository

Change the textual description, as returned by getDescription.

Specified by:

setDescription in interface StorableInStateRepository

compareTo

public int compareTo(StorableInStateRepository o)

Specified by:

compareTo in interface Comparable<StorableInStateRepository>