org.objectweb.proactive.scheduler
Class ProActiveJobHandler

java.lang.Object
  org.objectweb.proactive.core.xml.handler.AbstractUnmarshallerDecorator
      org.objectweb.proactive.scheduler.ProActiveJobHandler

All Implemented Interfaces:

ProActiveDescriptorConstants, UnmarshallerHandler, XMLHandler

public class ProActiveJobHandler
extends AbstractUnmarshallerDecorator
implements ProActiveDescriptorConstants

This is the main class used for parsing the jobs submitted with the xml deployment descriptor file. This class will launch the parsing of the file and the extraction of the descriptions of the job.

Author:

cjarjouh

Field Summary

Fields inherited from interface org.objectweb.proactive.core.descriptor.xml.ProActiveDescriptorConstants

ABS_PATH_TAG, ACQUISITION_TAG, ARG_TAG, BOOKING_DURATION_TAG, BOOT_CLASSPATH_TAG, BSUB_OPTIONS_TAG, BSUB_PROCESS_TAG, CLASSNAME_TAG, CLASSPATH_TAG, CLUSTERFORK_PROCESS_TAG, COMMAND_PATH_TAG, COMPONENT_DEFINITION_TAG, COUNT_TAG, CREATION_PROCESS_TAG, CURRENTJVM_TAG, DEPENDENT_PROCESS_SEQUENCE_TAG, DEPLOYMENT_TAG, ENVIRONMENT_TAG, ERROR_FILE, EXECUTABLE_TAG, EXTENDED_JVM_TAG, FILE_TRANSFER_COPY_PROTOCOL_TAG, FILE_TRANSFER_DEFINITIONS_TAG, FILE_TRANSFER_DEPLOY_TAG, FILE_TRANSFER_DIR_TAG, FILE_TRANSFER_DST_INFO_TAG, FILE_TRANSFER_FILE_TAG, FILE_TRANSFER_IMPLICT_KEYWORD, FILE_TRANSFER_RETRIEVE_TAG, FILE_TRANSFER_SRC_INFO_TAG, FILE_TRANSFER_TAG, FT_CKPTSERVER_TAG, FT_CONFIG_TAG, FT_GLOBALSERVER_TAG, FT_LOCSERVER_TAG, FT_PROTO_TAG, FT_RECPROCESS_TAG, FT_RESSERVER_TAG, FT_TTCVALUE_TAG, GLITE_ARGUMENTS_TAG, GLITE_CONFIG_TAG, GLITE_ENVIRONMENT_TAG, GLITE_INPUTDATA_TAG, GLITE_INPUTSANDBOX_TAG, GLITE_OUTPUTSANDBOX_TAG, GLITE_PATH_TAG, GLITE_PROCESS_OPTIONS_TAG, GLITE_PROCESS_TAG, GLITE_RANK_TAG, GLITE_REMOTE_PATH_TAG, GLITE_REQUIREMENTS_TAG, GLOBUS_MAXTIME_TAG, GLOBUS_OPTIONS_TAG, GLOBUS_PROCESS_TAG, GRID_ENGINE_OPTIONS_TAG, GRID_ENGINE_PROCESS_TAG, HIERARCHICAL_PROCESS_TAG, HIERARCHICIAL_REFERENCE_TAG, HOST_LIST_TAG, HOSTS_NUMBER_TAG, INFRASTRUCTURE_TAG, JAVA_PATH_TAG, JVM_PROCESS_TAG, JVM_TAG, JVMPARAMETER_TAG, JVMPARAMETERS_TAG, JVMS_TAG, JVMSET_TAG, LOG4J_FILE_TAG, LOOKUP_TAG, MAIN_DEFINITION_TAG, MAP_TAG, MAP_TO_VIRTUAL_NODE_TAG, MAPPING_TAG, MAPRSH_PROCESS_TAG, MPI_LOCAL_PATH_TAG, MPI_PROCESS_OPTIONS_TAG, MPI_PROCESS_TAG, MPI_REMOTE_PATH_TAG, NG_OPTIONS_TAG, NG_PROCESS_TAG, OAR_OPTIONS_TAG, OAR_PROCESS_TAG, OAR_RESOURCE_TAG, OARGRID_OPTIONS_TAG, OARGRID_PROCESS_TAG, OARGRID_WALLTIME_TAG, OUTPUT_FILE, P2P_SERVICE_TAG, PARALLEL_ENVIRONMENT_TAG, PARAMETERS_TAG, PBS_OPTIONS_TAG, PBS_PROCESS_TAG, PEER_TAG, PEERS_SET_TAG, POLICY_FILE_TAG, PROACTIVE_DESCRIPTOR_TAG, PROACTIVE_PROPS_FILE_TAG, PROACTIVE_SCHEDULER_TAG, PROCESS_DEFINITION_TAG, PROCESS_LIST_BYHOST_TAG, PROCESS_LIST_TAG, PROCESS_NUMBER_TAG, PROCESS_REFERENCE_TAG, PROCESS_TAG, PROCESSES_TAG, PROCESSOR_PER_NODE_TAG, PROCESSOR_TAG, PRUN_OPTIONS_TAG, PRUN_PROCESS_TAG, QUEUE_NAME_TAG, REGISTER_TAG, REL_PATH_TAG, RES_REQ_TAG, RLOGIN_PROCESS_TAG, RMI_LOOKUP_TAG, RSH_PROCESS_TAG, SCRIPT_PATH_TAG, SECURITY_TAG, SEQUENTIAL_PROCESS_TAG, SERVICE_DEFINITION_TAG, SERVICE_REFERENCE_TAG, SERVICES_TAG, SSH_PROCESS_TAG, TECHNICAL_SERVICE_ARG_TAG, TECHNICAL_SERVICE_ID, TECHNICAL_SERVICES_DEF_TAG, TECHNICAL_SERVICES_TAG, UNICORE_DIR_PATH_TAG, UNICORE_KEYFILE_PATH_TAG, UNICORE_OPTIONS_TAG, UNICORE_PROCESS_TAG, UNICORE_USITE_TAG, UNICORE_VSITE_TAG, VARIABLE_TAG, VARIABLES_DESCRIPTOR_DEFAULT_TAG, VARIABLES_DESCRIPTOR_TAG, VARIABLES_INCLUDE_PROPERTY_FILE_TAG, VARIABLES_INCLUDE_XML_FILE_TAG, VARIABLES_JAVAPROPERTY_DESCRIPTOR_TAG, VARIABLES_JAVAPROPERTY_PROGRAM_TAG, VARIABLES_JAVAPROPERTY_TAG, VARIABLES_PROGRAM_DEFAULT_TAG, VARIABLES_PROGRAM_TAG, VARIABLES_TAG, VIRTUAL_NODE_TAG, VIRTUAL_NODES_ACQUISITION_TAG, VIRTUAL_NODES_DEFINITION_TAG, VMNAME_TAG

Fields inherited from interface org.objectweb.proactive.core.xml.handler.UnmarshallerHandler

logger

Constructor Summary

ProActiveJobHandler(Scheduler scheduler, java.lang.String jobId, java.lang.String xmlDescriptorUrl)

Method Summary

java.lang.Object	getResultObject() Returns the object resulting of the processing of the SAX events.
protected void	notifyEndActiveHandler(java.lang.String name, UnmarshallerHandler activeHandler) we redefine this method so that we can collect in the end the total amount of information from the created Virtual nodes.
void	startContextElement(java.lang.String name, Attributes attributes) Receives notification that the XML element of given name and attributes has been read in the XML being deserialized.

Methods inherited from class org.objectweb.proactive.core.xml.handler.AbstractUnmarshallerDecorator

addHandler, checkActiveHandler, checkNonEmpty, endElement, endPrefixMapping, getHandler, readValue, startElement, startPrefixMapping

Methods inherited from class java.lang.Object

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

Constructor Detail

ProActiveJobHandler

public ProActiveJobHandler(Scheduler scheduler,
                           java.lang.String jobId,
                           java.lang.String xmlDescriptorUrl)

Method Detail

getResultObject

public java.lang.Object getResultObject()
                                 throws org.xml.sax.SAXException

Description copied from interface: UnmarshallerHandler

Returns the object resulting of the processing of the SAX events.

Specified by:

getResultObject in interface UnmarshallerHandler

Returns:

the object resulting of the processing of the SAX events or null

Throws:

org.xml.sax.SAXException - if the state of the handler does not allow to return any resulting object.

startContextElement

public void startContextElement(java.lang.String name,
                                Attributes attributes)
                         throws org.xml.sax.SAXException

Description copied from interface: UnmarshallerHandler

Receives notification that the XML element of given name and attributes has been read in the XML being deserialized. This element is the context element of the Object being unmarshalled. This context element is the element that has triggered the use of this handler.

Specified by:

startContextElement in interface UnmarshallerHandler

Parameters:

name - the name of the element just opened

attributes - the attributes of this element

Throws:

org.xml.sax.SAXException - if an exception occur during processing

notifyEndActiveHandler

protected void notifyEndActiveHandler(java.lang.String name,
                                      UnmarshallerHandler activeHandler)
                               throws org.xml.sax.SAXException

we redefine this method so that we can collect in the end the total amount of information from the created Virtual nodes. Like for instance the total amount of needed ressources.

Specified by:

notifyEndActiveHandler in class AbstractUnmarshallerDecorator

Throws:

org.xml.sax.SAXException