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, DataStagerManager

public class DataStagerManagerImpl
extends Object
implements DataStagerManager

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(StateRepository repository, org.apache.axis.message.addressing.EndpointReferenceType EPR)
Constructs a new manager.

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.
Class<DataStagerManager>	getInterface() Returns the type of this object.
URL	getParentURL() Returns the URL of this object's parent.
StateRepository	getRepository() Get the StateRepository holding this object.
URL	getURL() Returns the globally unique identifier.
void	setDescription(String description) Change the textual description, as returned by getDescription.
void	setRepository(StateRepository repository)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataStagerManagerImpl

public DataStagerManagerImpl(StateRepository repository,
                             org.apache.axis.message.addressing.EndpointReferenceType EPR)
                      throws ObjectAlreadyExists

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

Parameters:

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

Throws:

ObjectAlreadyExists

Method Detail

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 GridFailureException

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:

GridFailureException

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

getInterface

public Class<DataStagerManager> getInterface()

Description copied from interface: StorableInStateRepository

Returns the type of this object. When loading the object, a StateRepository locates a class implementing the interface and uses that for the object.

Specified by:

getInterface in interface StorableInStateRepository

getParentURL

public URL getParentURL()

Description copied from interface: StorableInStateRepository

Returns the URL of this object's parent. Returns null if this is a top-level (service) object.

Specified by:

getParentURL in interface StorableInStateRepository

getRepository

public StateRepository getRepository()

Description copied from interface: StorableInStateRepository

Get the StateRepository holding this object.

Specified by:

getRepository 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

setRepository

public void setRepository(StateRepository repository)

compareTo

public int compareTo(StorableInStateRepository o)

Specified by:

compareTo in interface Comparable<StorableInStateRepository>