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

java.lang.Object
  extended byorg.globus.ogsa.impl.core.service.ServicePropertiesImpl
      extended byorg.globus.ogsa.impl.ogsi.GridServiceImpl
          extended byorg.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