uk.ac.soton.itinnovation.grid.comms.data
Interface DataEventListener

All Known Implementing Classes:

JobServiceModule

public interface DataEventListener

Interface that can be implemented by a service to receive messages from a DataStagerManager. All methods here take a DataStagerManager argument. These managers are initialised by the data service with the EPR of the resource that owns the data stagers. This allows the service to find out which owning resource should be used to report usage.

Method Summary

void	dataStagerAddCumulativeUsageReport(DataStagerManager manager, 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(DataStagerManager manager, org.apache.axis.message.addressing.EndpointReferenceType stagerEPR, Constraint[] constraints) Called when a data stager makes a continueActivity request.
void	dataStagerInstantaneousUsageChanged(DataStagerManager manager, Metric metric) Called when a data stager generates an instantaneous usage report.
void	dataStagerStartActivity(DataStagerManager manager, Constraint[] constraints, UsageReport[] usageReports) Called when a data stager makes a startActivity request.

Method Detail

dataStagerStartActivity

void dataStagerStartActivity(DataStagerManager manager,
                             Constraint[] constraints,
                             UsageReport[] usageReports)

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

Parameters:

manager - The DataStagerManager that is responsible for the stager.

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

usageReports - An array of initial usage reports.

dataStagerContinueActivity

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

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

Parameters:

manager - The DataStagerManager that is responsible for the stager.

stagerEPR -

constraints - An array of constraints that must be satisfied.

Throws:

RemoteException

dataStagerAddCumulativeUsageReport

void dataStagerAddCumulativeUsageReport(DataStagerManager manager,
                                        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.

Parameters:

manager - The DataStagerManager that is responsible for the stager.

metric - The metric type of the resource being used

value - The cumulative increase in use of the metric

dataStagerInstantaneousUsageChanged

void dataStagerInstantaneousUsageChanged(DataStagerManager manager,
                                         Metric metric)
                                         throws GridFailureException

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.

Parameters:

manager - The DataStagerManager that is responsible for the stager.

metric - The metric type of the resource being used

Throws:

GridFailureException