Package com.j_spaces.core.admin

Class JSpaceAdminImpl

java.lang.Object

com.j_spaces.core.service.ServiceAdminImpl

com.j_spaces.core.admin.JSpaceAdminImpl

All Implemented Interfaces:

GridZoneProvider, JVMInfoProvider, OSInfoProvider, NIOInfoProvider, IInternalRemoteJSpaceAdmin, IRemoteJSpaceAdmin, StatisticsAdmin, ServiceAdmin, DestroyAdmin, Remote, JoinAdmin

public class JSpaceAdminImpl
extends ServiceAdminImpl
implements IInternalRemoteJSpaceAdmin, StatisticsAdmin

Copyright (c) 2010 GigaSpaces Technologies Ltd. All rights reserved The software source code is proprietary and confidential information of GigaSpaces. You may use the software source code solely under the terms and limitations of The license agreement granted to you by GigaSpaces.

Field Summary

Fields inherited from class com.j_spaces.core.service.ServiceAdminImpl

joinManagerNullException, m_adminProxy, m_exporter, m_service, m_thisRemoteRef, MAX_UNEXPORT_DELAY

Fields inherited from interface com.j_spaces.core.admin.IRemoteJSpaceAdmin

REPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED

Constructor Summary

Constructors

Constructor	Description
JSpaceAdminImpl(AbstractService service, Exporter exporter)

Method Summary

Modifier and Type	Method	Description
SpaceMode	addSpaceModeListener(ISpaceModeListener listener)	Adds a listener to be called back with ISpaceModeListener mode changes.
SuspendType	addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)	Adds a listener to be called back with SuspendTypeChangedInternalListener suspend type changes.
int	countIncomingConnections()
int	countTransactions(int type, int status)
void	disableLRMIMonitoring()	Disabled lrmi monitoring (gigaspaces internal remoting layer).
void	disableStub()	disable remote.
void	dropClass(String className, SpaceContext sc)	Drop all Class entries and all its templates from the space.
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.
int	flushRedoLogToStorage()	Flush redo-log packets from memory to underlying storage.
void	forceMoveToPrimary()	Forcefully make this space to be primary
ITypeDesc	getClassDescriptor(String className)	Get the basic class information from the space directory.
ITypeDesc	getClassDescriptor(String className, boolean asVirtualType)	Get the basic class information from the space directory.
BasicTypeInfo	getClassTypeInfo(String className)	Get the basic class information from the space directory.
byte[]	getClusterConfigFile()	Returns a byte representation of the cluster configuration file.
ClusterPolicy	getClusterPolicy()	Return the present ClusterPolicy objects.
SpaceConfig	getConfig()	Returns SpaceConfig of this space.
List<ITransportConnection>	getConnectionsInfo()
long	getCurrentTimestamp()
StatisticsHolder	getHolder()
JVMDetails	getJVMDetails()
JVMStatistics	getJVMStatistics()
Map<String,LocalCacheDetails>	getLocalCacheDetails()
Map<String,LocalViewDetails>	getLocalViewDetails()
List<UnderTxnLockedObject>	getLockedObjects(Transaction txn)	getLockedObjects is called by the GUI.
Map<String,Object>	getMetricSnapshots(Collection<String> prefixes)
String	getName()	Returns the Space Name.
NIODetails	getNIODetails()	Returns the transport configuration.
NIOStatistics	getNIOStatistics()	Returns the transport statistics.
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
ServiceAdmin	getProxy()	Overload method;
String	getReplicationDump()
ReplicationStatistics	getReplicationStatistics()
Object[]	getReplicationStatus()	returns the replication member-status relation of all the replication groups.
RuntimeHolder	getRuntimeHolder()
SpaceRuntimeInfo	getRuntimeInfo()	Returns SpaceRuntimeInfo.
SpaceRuntimeInfo	getRuntimeInfo(String className)	Returns SpaceRuntimeInfo for specific class name and its subclasses.
SpaceInstanceRemoteClassLoaderInfo	getSpaceInstanceRemoteClassLoaderInfo()	Return the info about the space classloader
SpaceMode	getSpaceMode()	Get the current SpaceMode which represents the current state of this participant in the election process.
int	getState()	Returns the particular condition of this space.
Map<Integer,StatisticsContext>	getStatistics()	Returns statistics repository that contains a map of operation codes to StatisticsContext objects for all filter operation codes.
StatisticsContext	getStatistics(int operationCode)	Returns a StatisticsContext for specific filter operation code.
Map<Integer,StatisticsContext>	getStatistics(Integer[] operationCodes)	Returns statistics repository that contains a map of operation codes to StatisticsContext objects for passed specific filter operation codes.
long	getStatisticsSamplingRate()	Checks statistics sampling rate.
String[]	getStatisticsStringArray()	Returns a string array contains statistics values for each operation.
List<TemplateInfo>	getTemplatesInfo(String className)	Returns a list of pending templates.
TransactionInfo[]	getTransactionsInfo(int type, int status)	Returns all the transactions with the specific parameters.
String[]	getZones()
boolean	isStartedWithinGSC()
boolean	isStatisticsAvailable()	Checks if space statistics is available.
void	ping()	Ping to space to see if alive.
void	removeSpaceModeListener(ISpaceModeListener listener)	Removes this listener so that it no longer receives call backs of space mode changes.
void	removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)	Removes this listener so that it no longer receives call backs of space suspend type changes.
void	restart()	Restarts the space.
void	runGc()
void	setClusterConfigFile(byte[] config)	set the cluster configuration according to the given byte representation of the configuration file.
void	setStatisticsSamplingRate(long rate)	Set statistics sampling rate.
SpaceCopyStatus	spaceCopy(IRemoteSpace remoteProxy, String remoteSpaceUrl, String remoteSpaceName, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext sc, SpaceContext remoteSpaceContext)	Given ISpaceInternal of a remote space, Copy all entries/notify templates from the space.
SpaceCopyStatus	spaceCopy(IJSpace remoteSpace, Object template, boolean includeNotifyTemplates, int chunkSize)
SpaceCopyStatus	spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize)	Given Url of a remote space, Copy all entries/notify templates from the space.
SpaceCopyStatus	spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext sc)	Given Url of a remote space, Copy all entries/notify templates from the space.
SpaceCopyStatus	spaceCopy(String remoteUrl, Object template, boolean includeNotifyTemplates, int chunkSize)	Igor.G 13/3/2005 ver 5.01.
void	start()	Attempt to start this space.
void	stop()	Attempt to stop this space.
void	updateClusterInfo()	trigger read of chunks map from zk and update clusterInfo

Methods inherited from class com.j_spaces.core.service.ServiceAdminImpl

addLookupAttributes, addLookupGroups, addLookupLocators, destroy, getLookupAttributes, getLookupGroups, getLookupLocators, modifyLookupAttributes, removeLookupGroups, removeLookupLocators, setLookupGroups, setLookupLocators, unexport, validateJoinManager

Methods inherited from class java.lang.Object

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

Constructor Details

JSpaceAdminImpl

public JSpaceAdminImpl(AbstractService service,
 Exporter exporter)
                throws RemoteException

Parameters:

service -

exporter -

Throws:

RemoteException

Method Details

getProxy

public ServiceAdmin getProxy()

Overload method;

Overrides:

getProxy in class ServiceAdminImpl

See Also:

• ServiceAdminImpl.getProxy()

restart

public void restart()
             throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Restarts the space.

 Usage:
   try
   {
  spaceAdmin.restart();
   }
   catch( java.rmi.RemoteException ex )
   {
  System.err.println("Failed to restart space: " + ((IJSpace)space).getName());
  System.err.println("Exception: " + ex);
   }
 

Specified by:

restart in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException - Failed to restart space.

addSpaceSuspendTypeListener

public SuspendType addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)

Description copied from interface: IInternalRemoteJSpaceAdmin

Adds a listener to be called back with SuspendTypeChangedInternalListener suspend type changes.

Specified by:

addSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdmin

Parameters:

listener - - SuspendTypeChangedInternalListener that will receive notification when a space suspend type changes (SuspendType)

removeSpaceSuspendTypeListener

public void removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)

Description copied from interface: IInternalRemoteJSpaceAdmin

Removes this listener so that it no longer receives call backs of space suspend type changes.

Specified by:

removeSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdmin

Parameters:

listener - - SuspendTypeChangedInternalListener that will stop receiving notification when a space suspend type changes (SuspendType)

getSpaceInstanceRemoteClassLoaderInfo

public SpaceInstanceRemoteClassLoaderInfo getSpaceInstanceRemoteClassLoaderInfo()
                                                                         throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Return the info about the space classloader

Specified by:

getSpaceInstanceRemoteClassLoaderInfo in interface IRemoteJSpaceAdmin

Returns:

a SpaceInstanceRemoteClassLoaderInfo that represents the space classloader's

Throws:

RemoteException - if a communication error occurs

updateClusterInfo

public void updateClusterInfo()
                       throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

trigger read of chunks map from zk and update clusterInfo

Specified by:

updateClusterInfo in interface IRemoteJSpaceAdmin

Throws:

RemoteException - if a communication error occurs

getName

public String getName()
               throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns the Space Name.

 Usage:
        spaceAdmin.getName()
 

Specified by:

getName in interface IRemoteJSpaceAdmin

Returns:

the space's name

Throws:

RemoteException - Failed to get name

getRuntimeInfo

public SpaceRuntimeInfo getRuntimeInfo()
                                throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns SpaceRuntimeInfo.

 Usage:
   SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo();
   List classNames = runtime.m_ClassNames;
   List numOfEntries = runtime.m_NumOFEntries;
 

Specified by:

getRuntimeInfo in interface IRemoteJSpaceAdmin

Returns:

SpaceRuntimeInfo which holds the classes and the number of entries currently in the space.

Throws:

RemoteException - if a communication error occurs

getRuntimeInfo

public SpaceRuntimeInfo getRuntimeInfo(String className)
                                throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns SpaceRuntimeInfo for specific class name and its subclasses.

 Usage:
         String className = ExampleObject.class.getName();
   SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo(className);
   List classNames = runtime.m_ClassNames;
   List numOfEntries = runtime.m_NumOFEntries;
 

Specified by:

getRuntimeInfo in interface IRemoteJSpaceAdmin

Returns:

SpaceRuntimeInfo which holds the classes and the number of entries of given class and its subclasses currently in space.

Throws:

RemoteException - if a communication error occurs

getReplicationStatistics

public ReplicationStatistics getReplicationStatistics()
                                               throws RemoteException

Specified by:

getReplicationStatistics in interface IRemoteJSpaceAdmin

Throws:

RemoteException

getConfig

public SpaceConfig getConfig()
                      throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns SpaceConfig of this space.

 Usage:
        SpaceConfig config = spaceAdmin.getConfig();
        if (config != null)
                boolean isClustered = config.m_isClustered;
 

Specified by:

getConfig in interface IRemoteJSpaceAdmin

Returns:

SpaceConfig - Contains all information about the space configuration.

Throws:

RemoteException - if a communication error occurs

ping

public void ping()
          throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Ping to space to see if alive. If successful, this does not indicate that the space is in a running state.

Usage:
 try
 {
     spaceAdmin.ping();
 }
 catch (RemoteException re)
 {
     System.err.println("Space not accessible");
 }

Specified by:

ping in interface IRemoteJSpaceAdmin

Throws:

RemoteException - if a communication error occurs

See Also:

• IRemoteJSpaceAdmin.getState()

disableStub

public void disableStub()
                 throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

disable remote.

Specified by:

disableStub in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException - if a communication error occurs

getReplicationStatus

public Object[] getReplicationStatus()
                              throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

returns the replication member-status relation of all the replication groups.

 Usage:
   Object[] replStatus = spaceAdmin.getReplicationStatus();
   String[] peers = (String[])replStatus[0];
   int[] status = (int[])replStatus[1];
 

Specified by:

getReplicationStatus in interface IRemoteJSpaceAdmin

Returns:

an array of remote member names array and replication status array. Replication status can have one of the following values: IRemoteJSpaceAdmin.REPLICATION_STATUS_ACTIVE IRemoteJSpaceAdmin.REPLICATION_STATUS_DISCONNECTED IRemoteJSpaceAdmin.REPLICATION_STATUS_DISABLED

Throws:

RemoteException - if a communication error occurs

getRuntimeHolder

public RuntimeHolder getRuntimeHolder()
                               throws RemoteException

Specified by:

getRuntimeHolder in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

isStartedWithinGSC

public boolean isStartedWithinGSC()
                           throws RemoteException

Specified by:

isStartedWithinGSC in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

getClassDescriptor

public ITypeDesc getClassDescriptor(String className)
                             throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Get the basic class information from the space directory.

 Usage:
   com.j_spaces.core.client.BasicTypeInfo classInfo
        = spaceAdmin.getClassTypeInfo( className );

   String[] fieldNames = classInfo.m_FieldsNames;
   String[] fieldTypes = classInfo.m_FieldsTypes;
 

Specified by:

getClassDescriptor in interface IInternalRemoteJSpaceAdmin

Parameters:

className - - The name of the class to retrieve the information from.

Returns:

BasicTypeInfo - Which provides class information.

Throws:

RemoteException - if a communication error occurs

getClassDescriptor

public ITypeDesc getClassDescriptor(String className,
 boolean asVirtualType)
                             throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Get the basic class information from the space directory.

 Usage:
   com.j_spaces.core.client.BasicTypeInfo classInfo
        = spaceAdmin.getClassTypeInfo( className );

   String[] fieldNames = classInfo.m_FieldsNames;
   String[] fieldTypes = classInfo.m_FieldsTypes;
 

Specified by:

getClassDescriptor in interface IInternalRemoteJSpaceAdmin

Parameters:

className - - The name of the class to retrieve the information from.

Returns:

BasicTypeInfo - Which provides class information.

Throws:

RemoteException - if a communication error occurs

getClassTypeInfo

public BasicTypeInfo getClassTypeInfo(String className)
                               throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Get the basic class information from the space directory.

 Usage:
   com.j_spaces.core.client.BasicTypeInfo classInfo
        = spaceAdmin.getClassTypeInfo( className );

   String[] fieldNames = classInfo.m_FieldsNames;
   String[] fieldTypes = classInfo.m_FieldsTypes;
 

Specified by:

getClassTypeInfo in interface IRemoteJSpaceAdmin

Parameters:

className - - The name of the class to retrieve the information from.

Returns:

BasicTypeInfo - Which provides class information.

Throws:

RemoteException - if a communication error occurs

getClusterPolicy

public ClusterPolicy getClusterPolicy()
                               throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Return the present ClusterPolicy objects.

Specified by:

getClusterPolicy in interface IRemoteJSpaceAdmin

Returns:

a ClusterPolicy that represents current cluster

Throws:

RemoteException - if a communication error occurs

dropClass

public void dropClass(String className,
 SpaceContext sc)
               throws RemoteException,
DropClassException

Description copied from interface: IRemoteJSpaceAdmin

Drop all Class entries and all its templates from the space. Calling this method will remove all internal meta data related to this class stored in the space. When using persistent spaced the relevant RDBMS table will be dropped. It is the caller responsibility to ensure that no entries from this class are written to the space while this method is called. This method is protected through the space Default Security Filter. Admin permissions required to execute this request successfully.

 Usage:
        spaceAdmin.dropClass( className );
 

Specified by:

dropClass in interface IRemoteJSpaceAdmin

Parameters:

className - name of class to delete.

Throws:

RemoteException - if a communication error occurs

DropClassException - Failed to drop desired class.

start

public void start()
           throws RemoteException,
SpaceAlreadyStartedException

Description copied from interface: IInternalRemoteJSpaceAdmin

Attempt to start this space.

 Usage:
  spaceAdmin.start();
 

Specified by:

start in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException - - Failed to start space.

SpaceAlreadyStartedException - - The space is already started

stop

public void stop()
          throws RemoteException,
SpaceAlreadyStoppedException

Description copied from interface: IInternalRemoteJSpaceAdmin

Attempt to stop this space.

 Usage:
  spaceAdmin.stop();
 

Specified by:

stop in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException - - Failed to stop space.

SpaceAlreadyStoppedException - - The space is already stopped

getTransactionsInfo

public TransactionInfo[] getTransactionsInfo(int type,
 int status)
                                      throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Returns all the transactions with the specific parameters.

Specified by:

getTransactionsInfo in interface IInternalRemoteJSpaceAdmin

Parameters:

type - TransactionInfo.Types.LOCAL, TransactionInfo.Types.JINI or TransactionInfo.Types.XA. Use TransactionInfo.Types.All for all types;

status - can be one of the status defined in TransactionConstants

Returns:

all the TransactionInfos of the transactions that matches the given parameters

Throws:

RemoteException - if a communication error occurs

See Also:

• IRemoteJSpaceAdmin

countTransactions

public int countTransactions(int type,
 int status)
                      throws RemoteException

Specified by:

countTransactions in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

getTemplatesInfo

public List<TemplateInfo> getTemplatesInfo(String className)
                                    throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Returns a list of pending templates.

Specified by:

getTemplatesInfo in interface IInternalRemoteJSpaceAdmin

Parameters:

className - name of the class to search

Returns:

list of pending template for the given class

Throws:

RemoteException

See Also:

• IInternalRemoteJSpaceAdmin.getTemplatesInfo(java.lang.String)

getConnectionsInfo

public List<ITransportConnection> getConnectionsInfo()
                                              throws RemoteException

Specified by:

getConnectionsInfo in interface IInternalRemoteJSpaceAdmin

Returns:

returns all the transport connection information for this Space.

Throws:

RemoteException

countIncomingConnections

public int countIncomingConnections()
                             throws RemoteException

Specified by:

countIncomingConnections in interface IInternalRemoteJSpaceAdmin

Returns:

returns all the transport connection information for this Space.

Throws:

RemoteException

getLockedObjects

public List<UnderTxnLockedObject> getLockedObjects(Transaction txn)
                                            throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

getLockedObjects is called by the GUI. it returns Info about all the locked Object by the given Transaction.

Specified by:

getLockedObjects in interface IInternalRemoteJSpaceAdmin

Parameters:

txn - - the Transaction that locks the Objects.

Returns:

List of UnderTxnLockedObject

Throws:

RemoteException

getState

public int getState()
             throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns the particular condition of this space.

Specified by:

getState in interface IRemoteJSpaceAdmin

Returns:

state - ISpaceState.STOPPED, ISpaceState.STARTED and etc.

Throws:

RemoteException - if a communication error occurs

See Also:

• ISpaceState

isStatisticsAvailable

public boolean isStatisticsAvailable()
                              throws RemoteException

Description copied from interface: StatisticsAdmin

Checks if space statistics is available.

Specified by:

isStatisticsAvailable in interface StatisticsAdmin

Returns:

true if space statistics is available

Throws:

RemoteException - if a communication error occurs

getStatisticsStringArray

public String[] getStatisticsStringArray()
                                  throws RemoteException

Description copied from interface: StatisticsAdmin

Returns a string array contains statistics values for each operation. For example: WRITE count: 10000, average time for last 2 seconds is 4293.1 READ count: 10000, average time for last 2 seconds is 4293.1

Specified by:

getStatisticsStringArray in interface StatisticsAdmin

Returns:

array of Strings that represents the space statistics

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

setStatisticsSamplingRate

public void setStatisticsSamplingRate(long rate)
                               throws RemoteException

Description copied from interface: StatisticsAdmin

Set statistics sampling rate.

Specified by:

setStatisticsSamplingRate in interface StatisticsAdmin

Parameters:

rate - the rate to sample the space for statistics

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

getStatisticsSamplingRate

public long getStatisticsSamplingRate()
                               throws RemoteException

Description copied from interface: StatisticsAdmin

Checks statistics sampling rate.

Specified by:

getStatisticsSamplingRate in interface StatisticsAdmin

Returns:

the statistics sampling rate

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

getStatistics

public StatisticsContext getStatistics(int operationCode)
                                throws RemoteException

Description copied from interface: StatisticsAdmin

Returns a StatisticsContext for specific filter operation code.

Specified by:

getStatistics in interface StatisticsAdmin

Parameters:

operationCode - filter operation code defined in FilterOperationCodes

Returns:

StatisticsContext for the given operation code

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

See Also:

• FilterOperationCodes

getHolder

public StatisticsHolder getHolder()
                           throws RemoteException

Specified by:

getHolder in interface StatisticsAdmin

Throws:

RemoteException

getMetricSnapshots

public Map<String,Object> getMetricSnapshots(Collection<String> prefixes)
                                      throws RemoteException

Specified by:

getMetricSnapshots in interface StatisticsAdmin

Parameters:

prefixes - collection of metrics prefixes

Returns:

map of metrics with their values as map values

Throws:

RemoteException

getStatistics

public Map<Integer,StatisticsContext> getStatistics(Integer[] operationCodes)
                                             throws RemoteException

Description copied from interface: StatisticsAdmin

Returns statistics repository that contains a map of operation codes to StatisticsContext objects for passed specific filter operation codes.

Specified by:

getStatistics in interface StatisticsAdmin

Parameters:

operationCodes - filter array of operation codes defined in FilterOperationCodes

Returns:

map of operation codes to StatisticsContext

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

getStatistics

public Map<Integer,StatisticsContext> getStatistics()
                                             throws RemoteException

Description copied from interface: StatisticsAdmin

Returns statistics repository that contains a map of operation codes to StatisticsContext objects for all filter operation codes.

Specified by:

getStatistics in interface StatisticsAdmin

Returns:

map of operation codes to StatisticsContext

Throws:

StatisticsNotAvailable - when space statistics are not available

RemoteException - if a communication error occurs

getClusterConfigFile

public byte[] getClusterConfigFile()
                            throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Returns a byte representation of the cluster configuration file.

Specified by:

getClusterConfigFile in interface IInternalRemoteJSpaceAdmin

Returns:

byte representation of the cluster configuration file

Throws:

RemoteException - if a communication error occurs

setClusterConfigFile

public void setClusterConfigFile(byte[] config)
                          throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

set the cluster configuration according to the given byte representation of the configuration file.

Specified by:

setClusterConfigFile in interface IInternalRemoteJSpaceAdmin

Parameters:

config - byte representation of the configuration file

Throws:

RemoteException - if a communication error occurs

spaceCopy

public SpaceCopyStatus spaceCopy(String remoteUrl,
 Object template,
 boolean includeNotifyTemplates,
 int chunkSize)
                          throws RemoteException

Igor.G 13/3/2005 ver 5.01. This method will never invoked! We have an abstraction problem with IRemoteJSpaceAdmin, JSpaceAdminProxy and SpaceInternal, so added method only to make compiler happy :(

Specified by:

spaceCopy in interface IRemoteJSpaceAdmin

Parameters:

remoteUrl - url of remote space to copy from

template - Entry template or null.

includeNotifyTemplates - - if true ALL notify templates will be copied too

chunkSize - Chunk size (batch) for this copy operation.

Returns:

SpaceCopyStatus Contains the status information of spaceCopy operation.

Throws:

RemoteException - if a communication error occurs

spaceCopy

public SpaceCopyStatus spaceCopy(String remoteUrl,
 ITemplatePacket template,
 boolean includeNotifyTemplates,
 int chunkSize)
                          throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Given Url of a remote space, Copy all entries/notify templates from the space.

 Usage:
   SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
   System.out.println("Copy-Status: " + copyStatus );
 

Specified by:

spaceCopy in interface IInternalRemoteJSpaceAdmin

Parameters:

remoteUrl - url of remote space to copy from

template - EntryPacket template or null.

includeNotifyTemplates - - if true ALL notify templates will be copied too

chunkSize - Chunk size (batch) for this copy operation.

Returns:

SpaceCopyStatus Contains the status information of spaceCopy operation.

Throws:

RemoteException - if a communication error occurs

spaceCopy

public SpaceCopyStatus spaceCopy(String remoteUrl,
 ITemplatePacket template,
 boolean includeNotifyTemplates,
 int chunkSize,
 SpaceContext sc)
                          throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Given Url of a remote space, Copy all entries/notify templates from the space.

 Usage:
   SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
   System.out.println("Copy-Status: " + copyStatus );
 

Specified by:

spaceCopy in interface IInternalRemoteJSpaceAdmin

Parameters:

remoteUrl - url of remote space to copy from

template - EntryPacket template or null.

includeNotifyTemplates - - if true ALL notify templates will be copied too

chunkSize - Chunk size (batch) for this copy operation.

sc - SpaceContext for security check in the server side.

Returns:

SpaceCopyStatus Contains the status information of spaceCopy operation.

Throws:

RemoteException - if a communication error occurs

spaceCopy

public SpaceCopyStatus spaceCopy(IRemoteSpace remoteProxy,
 String remoteSpaceUrl,
 String remoteSpaceName,
 ITemplatePacket template,
 boolean includeNotifyTemplates,
 int chunkSize,
 SpaceContext sc,
 SpaceContext remoteSpaceContext)
                          throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Given ISpaceInternal of a remote space, Copy all entries/notify templates from the space.

 Usage:
   SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( remoteProxy, remoteURL, remoteName,
 template, false 1000, sc);
   System.out.println("Copy-Status: " + copyStatus );
 

Specified by:

spaceCopy in interface IInternalRemoteJSpaceAdmin

Parameters:

remoteProxy - ISpaceInternal, a proxy to the remote space to copy from

remoteSpaceUrl - the remote space url.

remoteSpaceName - the remote space name.

template - A template for identified entries that should be copied.

includeNotifyTemplates - - if true ALL notify templates will be copied too

chunkSize - Chunk size (batch) for this copy operation.

sc - SpaceContext for security check in the server side.

remoteSpaceContext - remoteSpaceContext for security check in the server side.

Returns:

SpaceCopyStatus Contains the status information of spaceCopy operation.

Throws:

RemoteException - if a communication error occurs

spaceCopy

public SpaceCopyStatus spaceCopy(IJSpace remoteSpace,
 Object template,
 boolean includeNotifyTemplates,
 int chunkSize)
                          throws RemoteException

Specified by:

spaceCopy in interface IRemoteJSpaceAdmin

Throws:

RemoteException

getSpaceMode

public SpaceMode getSpaceMode()
                       throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Get the current SpaceMode which represents the current state of this participant in the election process.

In case of a non-clustered participant, where no election process takes place, the return value is always SpaceMode.PRIMARY.

Specified by:

getSpaceMode in interface IInternalRemoteJSpaceAdmin

Returns:

the current SpaceMode of the space.

Throws:

RemoteException - if an exception occurred executing this remote method.

addSpaceModeListener

public SpaceMode addSpaceModeListener(ISpaceModeListener listener)
                               throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Adds a listener to be called back with ISpaceModeListener mode changes. The change ( SpaceMode ) represents the result of an election process of this participant space. The returned value represents the current state of this participant in the election process.

In case of a non-clustered participant, the return value is always SpaceMode.PRIMARY. Hence, no election process will take place and the listener will not be called.

Specified by:

addSpaceModeListener in interface IInternalRemoteJSpaceAdmin

Parameters:

listener - a listener to be called back on space mode changes.

Returns:

the current SpaceMode of the space.

Throws:

RemoteException - if an exception occurred executing this remote method.

See Also:

• ISpaceModeListener
• SpaceMode

removeSpaceModeListener

public void removeSpaceModeListener(ISpaceModeListener listener)
                             throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Removes this listener so that it no longer receives call backs of space mode changes. Invocation has no additional effect if the listener was already removed or was not existent in the first place.

Specified by:

removeSpaceModeListener in interface IInternalRemoteJSpaceAdmin

Parameters:

listener - a listener to be removed.

Throws:

RemoteException - if an exception occurred executing this remote method.

See Also:

• IInternalRemoteJSpaceAdmin.addSpaceModeListener(ISpaceModeListener)

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

forceMoveToPrimary

public void forceMoveToPrimary()
                        throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Forcefully make this space to be primary

Specified by:

forceMoveToPrimary in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

getReplicationDump

public String getReplicationDump()
                          throws RemoteException

Specified by:

getReplicationDump in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

flushRedoLogToStorage

public int flushRedoLogToStorage()
                          throws RemoteException

Description copied from interface: IInternalRemoteJSpaceAdmin

Flush redo-log packets from memory to underlying storage. Should be called when the space is in quiesce mode.

Specified by:

flushRedoLogToStorage in interface IInternalRemoteJSpaceAdmin

Returns:

number of flushed packets

Throws:

RemoteException

getLocalCacheDetails

public Map<String,LocalCacheDetails> getLocalCacheDetails()
                                                   throws RemoteException

Specified by:

getLocalCacheDetails in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

getLocalViewDetails

public Map<String,LocalViewDetails> getLocalViewDetails()
                                                 throws RemoteException

Specified by:

getLocalViewDetails in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException