org.globus.ogsa.impl.base.gram.rips
Class RIPSImpl

java.lang.Object
  org.globus.ogsa.impl.core.service.ServicePropertiesImpl
      org.globus.ogsa.impl.ogsi.GridServiceImpl
          org.globus.ogsa.impl.base.gram.rips.RIPSImpl

All Implemented Interfaces:

org.gridforum.ogsi.GridService, org.globus.ogsa.GridServiceBase, org.globus.ogsa.GridServiceCallback, java.rmi.Remote, org.globus.ogsa.impl.base.providers.servicedata.ServiceDataProviderDocumentCallback, org.globus.ogsa.ServiceDataValueCallback, org.globus.ogsa.ServiceProperties

public class RIPSImpl

extends org.globus.ogsa.impl.ogsi.GridServiceImpl

implements org.globus.ogsa.impl.base.providers.servicedata.ServiceDataProviderDocumentCallback

GRAM Resource Information Provider Service

Field Summary

static java.lang.String	RIPS_NS
static java.lang.String	RIPS_NS_MAPPING
static java.lang.String	RIPS_NS_PREFIX

Fields inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

queryEngine, serviceData

Fields inherited from interface org.globus.ogsa.ServiceProperties

ACTIVATE_ON_STARTUP, ACTIVATION, BASE_CLASS_NAME, BOOTSTRAP, CONFIG_PATH, CONTAINS_REFERENCE, CREATION_EXTENSIBILITY, CREATION_EXTENSIBILITY_OUTPUT, CUSTOM_EXTENSIBILITY_DESERIALIZER, CUSTOM_EXTENSIBILITY_SERIALIZER, CUSTOM_MAPPING_REGISTERED, DEACTIVATED_PERSISTENT, DEACTIVATED_STATE, DEACTIVATED_TRANSIENT, DEACTIVATION, DESTROY_LISTENER, DESTRUCTION_SKELETON, DISABLE_FACTORY_REGISTRY, ENDPOINT, ENTRY_INSTANCE_CREATION, FACTORY, FACTORY_CALLBACK, FACTORY_HANDLE, FACTORY_PROVIDER, FACTORY_REGISTRY, GSR_DESCRIPTION, HANDLE, HANDLE_PORT, HANDLE_PROTOCOL, INSTANCE_CLASS, INSTANCE_DEACTIVATION, INSTANCE_GSR_DESCRIPTION, INSTANCE_LIFECYCLE, INSTANCE_PORT_TYPE, INSTANCE_PORT_TYPE_NS, INSTANCE_PREFIX, INSTANCE_REGISTRY, INSTANCE_SCHEMA_PATH, INSTANCE_WSDL, INTERFACE_CLASS_NAME, INVOCATION_ID, LAZY_CREATION, LIFECYCLE, LIFECYCLE_MONITOR, LIFECYCLE_MONITOR_CLASS, NAME, NOTIFICATION_ENGINE, NOTIFICATION_FACTORY, NOTIFICATION_SOURCE, OPERATION_PROVIDERS, PERSISTENT, PERSISTENT_PROPERTIES, PORT, PORT_TYPE, PORT_TYPE_NS, PRIMARY_KEY, PROTOCOL, QUERY_ENGINE, REDIRECT_RESOLVER, REGISTRY, RESOLVER_CACHE, ROUTER_HEADER, ROUTER_VIA, SCHEMA_LOCATION, SCHEMA_PATH, SERVICE_ACTIVATOR, SERVICE_DATA, SERVICE_DEPLOYMENT, SERVICE_GROUP_ENTRY, SERVICE_GROUP_PROVIDER, SERVICE_LOADER, SERVICE_NODE, SERVICE_PATH, SINK_ID, STARTUP_STATE, SWEEP_SERVICE_DATA, TIMEOUT, TIMESTAMP, TRANSIENT, TYPE, USER, WEBSTART_PANEL_NAME, WEBSTART_URL, WSDL

Constructor Summary

RIPSImpl()

Method Summary

org.globus.ogsa.base.providers.servicedata.ServiceDataProviderEnumType[]	enumProviders(boolean rescanConfig)
void	executeProvider(org.globus.ogsa.base.providers.servicedata.ServiceDataProviderExecutionType newServiceData)
java.lang.Class[]	getCallbackParamSig(java.lang.String methodName)
org.gridforum.ogsi.HandleType	getCurrentHandle()
java.lang.String	getDefaultCallbackMethodName()
java.lang.Object	getLock()
boolean	isLocked()
boolean	jobDataHandler(org.w3c.dom.Document doc, java.lang.Object context, java.lang.Integer providerState) TODO: add profiling to this routine
void	lock()
void	postCreate(org.globus.ogsa.GridContext context)
void	preDestroy(org.globus.ogsa.GridContext context)
void	subscribe(org.gridforum.ogsi.ExtensibilityType subscriptionExpression, org.gridforum.ogsi.LocatorType sink, org.gridforum.ogsi.ExtendedDateTimeType expirationTime, org.gridforum.ogsi.holders.LocatorTypeHolder subscriptionInstanceLocator, org.gridforum.ogsi.holders.TerminationTimeTypeHolder currentTerminationTime) Services may to subscribe to job elements where the intial state data might not exist yet, so the default behavior with RIPS will be to create an empty SDE as a placeholder, IFF there is no already existing SDE of the same name.
void	unlock()

Methods inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

activate, addOperationProvider, deactivate, destroy, findServiceData, getInstanceProperty, getOperationProvider, getQueryEngine, getServiceDataSet, getServiceDataValues, getServiceInterface, getTerminationTime, populateInstanceProperties, preCreate, removeOperationProvider, requestTerminationAfter, requestTerminationBefore, setDefaultTermination, setQueryEngine, setServiceData, setServiceDataSet

Methods inherited from class org.globus.ogsa.impl.core.service.ServicePropertiesImpl

flush, flush, getPersistentProperty, getProperty, keySet, setPersistentProperty, setProperty, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.ogsa.ServiceProperties

flush, getPersistentProperty, getProperty, setPersistentProperty, setProperty

Field Detail

RIPS_NS

public static final java.lang.String RIPS_NS

See Also:

Constant Field Values

RIPS_NS_PREFIX

public static final java.lang.String RIPS_NS_PREFIX

See Also:

Constant Field Values

RIPS_NS_MAPPING

public static final java.lang.String RIPS_NS_MAPPING

See Also:

Constant Field Values

Constructor Detail

RIPSImpl

public RIPSImpl()

Method Detail

getCurrentHandle

public org.gridforum.ogsi.HandleType getCurrentHandle()

getDefaultCallbackMethodName

public java.lang.String getDefaultCallbackMethodName()

Specified by:

getDefaultCallbackMethodName in interface org.globus.ogsa.impl.base.providers.servicedata.ServiceDataProviderDocumentCallback

getLock

public java.lang.Object getLock()

isLocked

public boolean isLocked()

lock

public void lock()

unlock

public void unlock()

getCallbackParamSig

public java.lang.Class[] getCallbackParamSig(java.lang.String methodName)

Specified by:

getCallbackParamSig in interface org.globus.ogsa.impl.base.providers.servicedata.ServiceDataProviderDocumentCallback

postCreate

public void postCreate(org.globus.ogsa.GridContext context)
                throws org.globus.ogsa.GridServiceException

Specified by:

postCreate in interface org.globus.ogsa.GridServiceCallback

Throws:

org.globus.ogsa.GridServiceException

preDestroy

public void preDestroy(org.globus.ogsa.GridContext context)
                throws org.globus.ogsa.GridServiceException

Specified by:

preDestroy in interface org.globus.ogsa.GridServiceCallback

Throws:

org.globus.ogsa.GridServiceException

enumProviders

public org.globus.ogsa.base.providers.servicedata.ServiceDataProviderEnumType[] enumProviders(boolean rescanConfig)
                                                                                       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

executeProvider

public void executeProvider(org.globus.ogsa.base.providers.servicedata.ServiceDataProviderExecutionType newServiceData)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

subscribe

public void subscribe(org.gridforum.ogsi.ExtensibilityType subscriptionExpression,
                      org.gridforum.ogsi.LocatorType sink,
                      org.gridforum.ogsi.ExtendedDateTimeType expirationTime,
                      org.gridforum.ogsi.holders.LocatorTypeHolder subscriptionInstanceLocator,
                      org.gridforum.ogsi.holders.TerminationTimeTypeHolder currentTerminationTime)
               throws java.rmi.RemoteException,
                      org.gridforum.ogsi.FaultType,
                      org.gridforum.ogsi.TargetInvalidFaultType,
                      org.gridforum.ogsi.ExtensibilityNotSupportedFaultType,
                      org.gridforum.ogsi.ExtensibilityTypeFaultType

Services may to subscribe to job elements where the intial state data might not exist yet, so the default behavior with RIPS will be to create an empty SDE as a placeholder, IFF there is no already existing SDE of the same name. The subscribe() method is overridden and a internal findService data is performed both to facilitate a security access gridmap lookup for job SDEs and generalized secure access for everything else.

Throws:

java.rmi.RemoteException

org.gridforum.ogsi.FaultType

org.gridforum.ogsi.TargetInvalidFaultType

org.gridforum.ogsi.ExtensibilityNotSupportedFaultType

org.gridforum.ogsi.ExtensibilityTypeFaultType

jobDataHandler

public boolean jobDataHandler(org.w3c.dom.Document doc,
                              java.lang.Object context,
                              java.lang.Integer providerState)
                       throws java.lang.Exception

TODO: add profiling to this routine

Throws:

java.lang.Exception