org.openspaces.grid.esm

Class ESMImpl

java.lang.Object

org.jini.rio.resources.servicecore.ServiceProvider

org.jini.rio.jsb.ServiceBeanAdapter

org.openspaces.grid.esm.ESMImpl

All Implemented Interfaces:

com.gigaspaces.grid.esm.ESM, AgentIdAware, GridZoneProvider, InternalDumpProvider, JVMInfoProvider, InternalLogProvider, OSInfoProvider, NIOInfoProvider, RemoteSecuredService, SecuredService, ServiceProxyAccessor, Remote, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, Administrable, ProxyAccessor, ServerProxyTrust, org.jini.rio.core.jsb.ServiceBean, ServiceState, MonitorableService, EventProducer, org.jini.rio.jsb.ServiceBeanAdapterMBean, Service, Watchable, AdminEventListener, MachineAddedEventListener, MachineLifecycleEventListener, MachineRemovedEventListener, ProcessingUnitAddedEventListener, ProcessingUnitRemovedEventListener

public class ESMImpl
extends org.jini.rio.jsb.ServiceBeanAdapter
implements ESM, RemoteSecuredService, ProcessingUnitRemovedEventListener, ProcessingUnitAddedEventListener, MachineLifecycleEventListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ESMImpl.PendingElasticPropertiesUpdate

Nested classes/interfaces inherited from class org.jini.rio.jsb.ServiceBeanAdapter

org.jini.rio.jsb.ServiceBeanAdapter.SnapshotThread

Field Summary

Fields

Modifier and Type	Field and Description
protected GigaSpace	managementSpace

Fields inherited from class org.jini.rio.jsb.ServiceBeanAdapter

activationID, computeResource, computeResourceObserver, context, contextClassLoader, contextMgr, joiner, jsbState, logDirName, mbeanNoticationInfoList, mbeanServer, objectName, proxy, serviceBeanComponent, serviceClassLoader, serviceID, slaThresholdEventAdapter, snapshotter, state, store, uuid

Fields inherited from class org.jini.rio.resources.servicecore.ServiceProvider

eventTable, watchRegistry

Constructor Summary

Constructors

Constructor and Description
ESMImpl() Create an ESM
ESMImpl(String[] configArgs, LifeCycle lifeCycle) Create an ESM launched from the ServiceStarter framework

Method Summary

Modifier and Type	Method and Description
void	advertise()
protected void	bootstrap(String[] configArgs)
protected Object	createProxy()
void	destroy(boolean force)
void	disableAgentFailureDetection(String processingUnitName, long timeout, TimeUnit timeunit) Disables failure detection for the agent on the machine that called this method.
void	disableLRMIMonitoring() Disabled lrmi monitoring (gigaspaces internal remoting layer).
byte[]	dumpBytes(String file, long from, int length)
void	enableAgentFailureDetection(String processingUnitName) Enables failure detection for the agent on the machine that called this method.
void	enableLRMIMonitoring() Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target to start track lrmi invocations which can later be viewed by calling.
LRMIMonitoringDetails	fetchLRMIMonitoringDetails() Return lrmi (gigaspaces internal remoting layer) services monitoring details.
InternalDumpResult	generateDump(String cause, Map<String,Object> context)
InternalDumpResult	generateDump(String cause, Map<String,Object> context, String... contributors)
int	getAgentId()
long	getCurrentTimestamp()
String	getGSAServiceID()
JVMDetails	getJVMDetails()
JVMStatistics	getJVMStatistics()
String[]	getManagedProcessingUnits()
NIODetails	getNIODetails() Returns the transport configuration.
NIOStatistics	getNIOStatistics() Returns the transport statistics.
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
ScaleStrategyConfig	getProcessingUnitScaleStrategyConfig(String processingUnitName)
Remote	getRemoteApi(String processingUnitName, String apiName)
org.jini.rio.monitor.event.Events	getScaleStrategyEvents(long cursor, int maxNumberOfEvents)
String[]	getZones()
void	initialize(org.jini.rio.core.jsb.ServiceBeanContext context)
boolean	isManagingProcessingUnit(String processingUnitName)
boolean	isManagingProcessingUnitAndScaleNotInProgress(String processingUnitName)
boolean	isServiceSecured() If a security model is defined will return true.
LogEntries	logEntriesDirect(LogEntryMatcher matcher)
SecurityContext	login(CredentialsProvider credentialsProvider) Login to a secured service using the provided credentialsProvider.
SecurityContext	login(SecurityContext securityContext) Login to a secured service using the provided SecurityContext
void	machineAdded(Machine machine) Called when a machine is added.
void	machineRemoved(Machine machine) Called when a machine is removed.
void	processingUnitAdded(ProcessingUnit pu) A callback indicating that a Processing Unit was added (deployed/discovered).
void	processingUnitRemoved(ProcessingUnit pu) A callback indicating that a Processing Unit was removed (undeployed).
void	reloadMetricConfiguration()
void	runGc()
void	setProcessingUnitElasticProperties(String puName, Map<String,String> properties)
void	setProcessingUnitScaleStrategy(String puName, ScaleStrategyConfig scaleStrategyConfig)

Methods inherited from class org.jini.rio.jsb.ServiceBeanAdapter

addAttribute, addAttributes, addNotificationListener, cleanClassLoaders, createObjectName, destroy, destroyJMX, doAdvertise, doInitialize, doStart, exportDo, getAdmin, getAdminExporter, getAssociationManagement, getAssociations, getDiscoveryManager, getExportedProxy, getExporter, getExporter, getJoinManager, getLookupGroups, getNotificationBroadcasterSupport, getNotificationInfo, getProxy, getProxyVerifier, getServiceBeanContext, getServiceID, getServiceProxy, getSLAEventHandler, getStarted, getStartTime, getState, getUuid, initialize, initializeJMX, monitor, ping, postDeregister, postRegister, preDeregister, preRegister, removeNotificationListener, removeNotificationListener, setLookupGroups, start, startHeartbeat, stop, unadvertise, undeployEvent

Methods inherited from class org.jini.rio.resources.servicecore.ServiceProvider

fetch, fetch, getConfiguration, getEventTable, getWatchRegistry, register, setConfiguration, setWatchRegistry

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.jini.admin.Administrable

getAdmin

Methods inherited from interface org.jini.rio.core.MonitorableService

monitor, ping, startHeartbeat

Methods inherited from interface org.jini.rio.event.EventProducer

register

Methods inherited from interface org.jini.rio.watch.Watchable

fetch, fetch

Methods inherited from interface com.gigaspaces.internal.log.InternalLogProvider

getManagerClusterInfo

Field Detail

managementSpace

protected GigaSpace managementSpace

Constructor Detail

ESMImpl

public ESMImpl()
        throws Exception

Create an ESM

Throws:

Exception

ESMImpl

public ESMImpl(String[] configArgs,
               LifeCycle lifeCycle)
        throws Exception

Create an ESM launched from the ServiceStarter framework

Throws:

Exception

Method Detail

bootstrap

protected void bootstrap(String[] configArgs)
                  throws Exception

Throws:

Exception

initialize

public void initialize(org.jini.rio.core.jsb.ServiceBeanContext context)
                throws Exception

Specified by:

initialize in interface org.jini.rio.core.jsb.ServiceBean

Overrides:

initialize in class org.jini.rio.jsb.ServiceBeanAdapter

Throws:

Exception

advertise

public void advertise()
               throws IOException

Specified by:

advertise in interface org.jini.rio.core.jsb.ServiceBean

Specified by:

advertise in interface org.jini.rio.jsb.ServiceBeanAdapterMBean

Overrides:

advertise in class org.jini.rio.jsb.ServiceBeanAdapter

Throws:

IOException

destroy

public void destroy(boolean force)

Specified by:

destroy in interface org.jini.rio.core.jsb.ServiceBean

Specified by:

destroy in interface org.jini.rio.jsb.ServiceBeanAdapterMBean

Overrides:

destroy in class org.jini.rio.jsb.ServiceBeanAdapter

createProxy

protected Object createProxy()

Overrides:

createProxy in class org.jini.rio.jsb.ServiceBeanAdapter

getAgentId

public int getAgentId()
               throws RemoteException

Specified by:

getAgentId in interface AgentIdAware

Throws:

RemoteException

getGSAServiceID

public String getGSAServiceID()
                       throws RemoteException

Specified by:

getGSAServiceID in interface AgentIdAware

Throws:

RemoteException

getNIODetails

public NIODetails getNIODetails()
                         throws RemoteException

Description copied from interface: NIOInfoProvider

Returns the transport configuration. Note, does not change during application lifecycle, should be cached on the client side.

Specified by:

getNIODetails in interface NIOInfoProvider

Throws:

RemoteException

getNIOStatistics

public NIOStatistics getNIOStatistics()
                               throws RemoteException

Description copied from interface: NIOInfoProvider

Returns the transport statistics.

Specified by:

getNIOStatistics in interface NIOInfoProvider

Throws:

RemoteException

enableLRMIMonitoring

public void enableLRMIMonitoring()
                          throws RemoteException

Description copied from interface: NIOInfoProvider

Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target to start track lrmi invocations which can later be viewed by calling. NIOInfoProvider.fetchLRMIMonitoringDetails()

Specified by:

enableLRMIMonitoring in interface NIOInfoProvider

Throws:

RemoteException

disableLRMIMonitoring

public void disableLRMIMonitoring()
                           throws RemoteException

Description copied from interface: NIOInfoProvider

Disabled lrmi monitoring (gigaspaces internal remoting layer). NIOInfoProvider.enableLRMIMonitoring()

Specified by:

disableLRMIMonitoring in interface NIOInfoProvider

Throws:

RemoteException

fetchLRMIMonitoringDetails

public LRMIMonitoringDetails fetchLRMIMonitoringDetails()
                                                 throws RemoteException

Description copied from interface: NIOInfoProvider

Return lrmi (gigaspaces internal remoting layer) services monitoring details. This will only work if lrmi monitoring was previously enabled, either by admin API, Jmx or system property. NIOInfoProvider.enableLRMIMonitoring()

Specified by:

fetchLRMIMonitoringDetails in interface NIOInfoProvider

Throws:

RemoteException

getCurrentTimestamp

public long getCurrentTimestamp()
                         throws RemoteException

Specified by:

getCurrentTimestamp in interface OSInfoProvider

Throws:

RemoteException

getOSDetails

public OSDetails getOSDetails()
                       throws RemoteException

Specified by:

getOSDetails in interface OSInfoProvider

Throws:

RemoteException

getOSStatistics

public OSStatistics getOSStatistics()
                             throws RemoteException

Specified by:

getOSStatistics in interface OSInfoProvider

Throws:

RemoteException

getJVMDetails

public JVMDetails getJVMDetails()
                         throws RemoteException

Specified by:

getJVMDetails in interface JVMInfoProvider

Throws:

RemoteException

getJVMStatistics

public JVMStatistics getJVMStatistics()
                               throws RemoteException

Specified by:

getJVMStatistics in interface JVMInfoProvider

Throws:

RemoteException

runGc

public void runGc()
           throws RemoteException

Specified by:

runGc in interface JVMInfoProvider

Throws:

RemoteException

getZones

public String[] getZones()
                  throws RemoteException

Specified by:

getZones in interface GridZoneProvider

Throws:

RemoteException

logEntriesDirect

public LogEntries logEntriesDirect(LogEntryMatcher matcher)
                            throws RemoteException,
                                   IOException

Specified by:

logEntriesDirect in interface InternalLogProvider

Throws:

RemoteException

IOException

reloadMetricConfiguration

public void reloadMetricConfiguration()
                               throws RemoteException

Specified by:

reloadMetricConfiguration in interface InternalDumpProvider

Throws:

RemoteException

dumpBytes

public byte[] dumpBytes(String file,
                        long from,
                        int length)
                 throws RemoteException,
                        IOException

Specified by:

dumpBytes in interface InternalDumpProvider

Throws:

RemoteException

IOException

generateDump

public InternalDumpResult generateDump(String cause,
                                       Map<String,Object> context)
                                throws RemoteException,
                                       InternalDumpException

Specified by:

generateDump in interface InternalDumpProvider

Throws:

RemoteException

InternalDumpException

generateDump

public InternalDumpResult generateDump(String cause,
                                       Map<String,Object> context,
                                       String... contributors)
                                throws RemoteException,
                                       InternalDumpException

Specified by:

generateDump in interface InternalDumpProvider

Throws:

RemoteException

InternalDumpException

getManagedProcessingUnits

public String[] getManagedProcessingUnits()

Specified by:

getManagedProcessingUnits in interface com.gigaspaces.grid.esm.ESM

isServiceSecured

public boolean isServiceSecured()
                         throws RemoteException

Description copied from interface: SecuredService

If a security model is defined will return true.

Specified by:

isServiceSecured in interface SecuredService

Returns:

true if secured; false otherwise.

Throws:

RemoteException - communication-related exceptions that may occur during the execution of a remote method call.

login

public SecurityContext login(CredentialsProvider credentialsProvider)
                      throws SecurityException,
                             RemoteException

Description copied from interface: SecuredService

Login to a secured service using the provided credentialsProvider.

Specified by:

login in interface SecuredService

Parameters:

credentialsProvider - provides credentials to be used for authentication.

Throws:

SecurityException - if authentication failed for any reason.

RemoteException - communication-related exceptions that may occur during the execution of a remote method call.

login

public SecurityContext login(SecurityContext securityContext)
                      throws RemoteException

Description copied from interface: RemoteSecuredService

Login to a secured service using the provided SecurityContext

Specified by:

login in interface RemoteSecuredService

Parameters:

securityContext - security context to be used for authentication.

Throws:

RemoteException - communication-related exceptions that may occur during the execution of a remote method call.

setProcessingUnitScaleStrategy

public void setProcessingUnitScaleStrategy(String puName,
                                           ScaleStrategyConfig scaleStrategyConfig)

getScaleStrategyEvents

public org.jini.rio.monitor.event.Events getScaleStrategyEvents(long cursor,
                                                                int maxNumberOfEvents)

setProcessingUnitElasticProperties

public void setProcessingUnitElasticProperties(String puName,
                                               Map<String,String> properties)
                                        throws RemoteException

Throws:

RemoteException

processingUnitRemoved

public void processingUnitRemoved(ProcessingUnit pu)

Description copied from interface: ProcessingUnitRemovedEventListener

A callback indicating that a Processing Unit was removed (undeployed).

Specified by:

processingUnitRemoved in interface ProcessingUnitRemovedEventListener

processingUnitAdded

public void processingUnitAdded(ProcessingUnit pu)

Description copied from interface: ProcessingUnitAddedEventListener

A callback indicating that a Processing Unit was added (deployed/discovered).

Specified by:

processingUnitAdded in interface ProcessingUnitAddedEventListener

machineAdded

public void machineAdded(Machine machine)

Description copied from interface: MachineAddedEventListener

Called when a machine is added.

Specified by:

machineAdded in interface MachineAddedEventListener

machineRemoved

public void machineRemoved(Machine machine)

Description copied from interface: MachineRemovedEventListener

Called when a machine is removed.

Specified by:

machineRemoved in interface MachineRemovedEventListener

getProcessingUnitScaleStrategyConfig

public ScaleStrategyConfig getProcessingUnitScaleStrategyConfig(String processingUnitName)
                                                         throws RemoteException

Throws:

RemoteException

isManagingProcessingUnit

public boolean isManagingProcessingUnit(String processingUnitName)
                                 throws RemoteException

Specified by:

isManagingProcessingUnit in interface com.gigaspaces.grid.esm.ESM

Throws:

RemoteException

isManagingProcessingUnitAndScaleNotInProgress

public boolean isManagingProcessingUnitAndScaleNotInProgress(String processingUnitName)
                                                      throws RemoteException

Specified by:

isManagingProcessingUnitAndScaleNotInProgress in interface com.gigaspaces.grid.esm.ESM

Throws:

RemoteException

getRemoteApi

public Remote getRemoteApi(String processingUnitName,
                           String apiName)
                    throws RemoteException

Throws:

RemoteException

disableAgentFailureDetection

public void disableAgentFailureDetection(String processingUnitName,
                                         long timeout,
                                         TimeUnit timeunit)
                                  throws RemoteException

Description copied from interface: ESM

Disables failure detection for the agent on the machine that called this method. This suppresses the creation of a new machine instead of the specified GSA if it is no longer running. It does not suppress the healing of GSCs on that GSA. Once the specified timeout expires, the failure detection is enabled automatically.

Throws:

RemoteException

See Also:

MachinesSlaEnforcementEndpoint#disableAgentFailureDetection(GridServiceAgent)

enableAgentFailureDetection

public void enableAgentFailureDetection(String processingUnitName)
                                 throws RemoteException

Description copied from interface: ESM

Enables failure detection for the agent on the machine that called this method.

Throws:

RemoteException

See Also:

MachinesSlaEnforcementEndpoint#enableAgentFailureDetection(GridServiceAgent)