org.inria.myriads.snoozenode.groupmanager.virtualclustermanager

Class VirtualClusterManager

java.lang.Object

org.inria.myriads.snoozenode.groupmanager.virtualclustermanager.VirtualClusterManager

All Implemented Interfaces:

VirtualClusterSubmissionListener

public final class VirtualClusterManager
extends Object
implements VirtualClusterSubmissionListener

Virtual Cluster Manager.

Author:

Eugen Feller

Constructor Summary

Constructors

Constructor and Description
VirtualClusterManager(NodeConfiguration nodeConfiguration, GroupLeaderRepository repository, ResourceDemandEstimator estimator) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected ArrayList<org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData>	generateVirtualMachineMetaData(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionRequest submissionRequest) Generates the virtual machine meta data.
org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionResponse	getVirtualClusterResponse(String taskIdentifier) Returns virtual cluster response if available.
void	onVirtualClusterSubmissionFinished(String taskIdentifier, org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionResponse response) Adds a virtual cluster response.
protected void	setVirtualMachineLocation(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachine, String hostId) Sets the virtual machine location in case of the user force destination for the virtual machine.
String	startVirtualClusterSubmission(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionRequest submissionRequest) Dispatches the virtual cluster submission request.

Methods inherited from class java.lang.Object

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

Constructor Detail

VirtualClusterManager

public VirtualClusterManager(NodeConfiguration nodeConfiguration,
                     GroupLeaderRepository repository,
                     ResourceDemandEstimator estimator)

Constructor.

Parameters:

nodeConfiguration - The node configuration

repository - The group leader repository

estimator - The resource demand estimator

Method Detail

generateVirtualMachineMetaData

protected ArrayList<org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData> generateVirtualMachineMetaData(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionRequest submissionRequest)
                                                                                                                                throws org.inria.myriads.snoozecommon.exception.VirtualClusterParserException

Generates the virtual machine meta data.

Parameters:

submissionRequest - The submission request

Returns:

The virtual machine meta data

Throws:

org.inria.myriads.snoozecommon.exception.VirtualClusterParserException - The virtual cluster parser exception

setVirtualMachineLocation

protected void setVirtualMachineLocation(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachine,
                             String hostId)

Sets the virtual machine location in case of the user force destination for the virtual machine.

Parameters:

virtualMachine - virtual machine meta data (under construction).

hostId - hostId

startVirtualClusterSubmission

public String startVirtualClusterSubmission(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionRequest submissionRequest)

Dispatches the virtual cluster submission request.

Parameters:

submissionRequest - The submission request

Returns:

The task identifier

onVirtualClusterSubmissionFinished

public void onVirtualClusterSubmissionFinished(String taskIdentifier,
                                      org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionResponse response)

Adds a virtual cluster response.

Specified by:

onVirtualClusterSubmissionFinished in interface VirtualClusterSubmissionListener

Parameters:

taskIdentifier - The task identifier

response - The virtual cluster response

getVirtualClusterResponse

public org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualClusterSubmissionResponse getVirtualClusterResponse(String taskIdentifier)

Returns virtual cluster response if available.

Parameters:

taskIdentifier - The task identifier

Returns:

The virtual cluster response