Package com.gigaspaces.internal.lrmi.stubs

Class LRMISpaceImpl

java.lang.Object

com.gigaspaces.lrmi.RemoteStub<IRemoteSpace>

com.gigaspaces.internal.lrmi.stubs.LRMISpaceImpl

All Implemented Interfaces:

GridZoneProvider, JVMInfoProvider, OSInfoProvider, RemoteOperationsExecutor, IRemoteSpace, ILRMIProxy, NIOInfoProvider, RemoteSecuredService, SmartExternalizable, IInternalRemoteJSpaceAdmin, IRemoteJSpaceAdmin, Service, ServiceProxyAccessor, Externalizable, Serializable, Remote, Administrable, TransactionConstants, TransactionParticipant

public class LRMISpaceImpl
extends RemoteStub<IRemoteSpace>
implements IRemoteSpace, IInternalRemoteJSpaceAdmin, Service

LRMI Stub implementation of IRemoteJSpaceImpl interface.

Version:

2.5

Author:

Igor Goldenberg

See Also:

• Serialized Form

Field Summary

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

REPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED

Fields inherited from interface net.jini.core.transaction.server.TransactionConstants

ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING

Constructor Summary

Constructors

Constructor	Description
LRMISpaceImpl()
LRMISpaceImpl(IRemoteSpace directRefObj, IRemoteSpace dynamicProxy)	constructor to initialize space stub

Method Summary

Modifier and Type	Method	Description
void	abort(TransactionManager parm1, long parm2)	Requests that the participant roll back any changes for the specified transaction and unlock any resources locked by the transaction.
void	abort(TransactionManager parm1, Object parm2)
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.
void	cancel(String entryUID, String classname, int objectType)
Exception[]	cancelAll(String[] entryUIDs, String[] classnames, int[] objectTypes)
ClusterTopology	checkChunkMapGeneration(int clientGeneration)
void	commit(TransactionManager parm1, long parm2)	Requests that the participant make all of its PREPARED changes for the specified transaction visible outside of the transaction and unlock any resources locked by the transaction.
void	commit(TransactionManager parm1, long parm2, int numOfParticipants)	Requests that the participant make all of its PREPARED changes for the specified transaction visible outside of the transaction and unlock any resources locked by the transaction.
void	commit(TransactionManager parm1, Object parm2)
void	commit(TransactionManager parm1, Object parm2, int numOfParticipants)
SpaceConnectResult	connect(SpaceConnectRequest request)
int	countIncomingConnections()
int	countTransactions(int type, int status)
void	demote(long maxSuspendTime, TimeUnit unit, SpaceContext sc)	Demote leadership and become a backup Space, in the specified operation timeout.
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.
<T extends RemoteOperationResult> T	executeOperation(RemoteOperationRequest<T> request)
<T extends RemoteOperationResult> T	executeOperationAsync(RemoteOperationRequest<T> request)
void	executeOperationOneway(RemoteOperationRequest<?> request)
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
Object	getAdmin()	Returns an object that implements whatever administration interfaces are appropriate for the particular service.
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()	Returns cluster policy.
SpaceConfig	getConfig()	Returns SpaceConfig of this space.
List<ITransportConnection>	getConnectionsInfo()
long	getCurrentTimestamp()
JVMDetails	getJVMDetails()
JVMStatistics	getJVMStatistics()
Map<String,LocalCacheDetails>	getLocalCacheDetails()
Map<String,LocalViewDetails>	getLocalViewDetails()
List<UnderTxnLockedObject>	getLockedObjects(Transaction txn)	getLockedObjects is called by the GUI.
String	getName()	Returns the Space Name.
NIODetails	getNIODetails()	Returns the transport configuration.
NIOStatistics	getNIOStatistics()	Returns the transport statistics.
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
IQueryProcessor	getQueryProcessor()
String	getReplicationDump()
IReplicationConnectionProxy	getReplicationRouterConnectionProxy()
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.
Object	getServiceProxy()	Returns a proxy object for this object.
SpaceHealthStatus	getSpaceHealthStatus()
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.
Uuid	getSpaceUuid()	returns the universal unique identifier of the remote space
int	getState()	Returns the particular condition of this space.
DirectPersistencySyncListBatch	getSynchronizationListBatch()
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	getUniqueID()	Generates and returns a unique id
String[]	getZones()
boolean	isActive()
boolean	isActiveAndNotSuspended()
Boolean	isActiveAsync()
boolean	isEmbedded()
boolean	isStartedWithinGSC()
Class<?>	loadRemoteClass(String className)
SecurityContext	login(SecurityContext securityContext)	Login to a secured service using the provided SecurityContext
void	ping()	Ping to space to see if alive.
int	prepare(TransactionManager parm1, long parm2)	Requests that the participant prepare itself to commit the transaction, and to vote on the outcome of the transaction.
Object	prepare(TransactionManager parm1, long parm2, boolean parm3)
int	prepare(TransactionManager parm1, Object parm2)
Object	prepare(TransactionManager parm1, Object parm2, boolean parm3)
int	prepare(TransactionManager parm1, Object parm2, int numOfParticipants)
Object	prepare(TransactionManager parm1, Object parm2, int parm3, boolean parm4)
int	prepareAndCommit(TransactionManager parm1, long parm2)	A combination of prepare and commit, which can be used by the manager when there is just one participant left to prepare and all other participants (if any) have responded with NOTCHANGED.
int	prepareAndCommit(TransactionManager parm1, Object parm2)
void	quiesce(String description, QuiesceToken token, boolean readonly)
void	readExternal(ObjectInput in)
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.
long	renew(String entryUID, String classname, int objectType, long duration)
Object[]	renewAll(String[] entryUIDs, String[] classnames, int[] objectTypes, long[] durations)
void	renewLease(TransactionManager mgr, long id, long time)	Notify the transaction participant about transaction lease renewal
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	snapshot(ITemplatePacket e)
void	snapshot(ITemplatePacket e, SpaceContext sc)
SpaceCopyStatus	spaceCopy(IRemoteSpace remoteProxy, String remoteSpaceUrl, String remoteSpaceName, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext spaceContext, 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	unquiesce()
void	updateClusterInfo()	trigger read of chunks map from zk and update clusterInfo

Methods inherited from class com.gigaspaces.lrmi.RemoteStub

closeProxy, disable, enable, equals, getConnectionUrl, getDynamicProxy, getGeneratedTraffic, getProxy, getReceivedTraffic, getRemoteHostAddress, getRemoteHostName, getRemoteNetworkAddress, getRemoteProcessId, getServicePlatformLogicalVersion, getStubId, hashCode, init, isClosed, isCollocated, isCollocatedStub, isDirect, isRemote, isStub, overrideMethodsMetadata, toString, writeExternal

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

LRMISpaceImpl

public LRMISpaceImpl()

LRMISpaceImpl

public LRMISpaceImpl(IRemoteSpace directRefObj,
 IRemoteSpace dynamicProxy)

constructor to initialize space stub

Method Details

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in interface IRemoteSpace

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

isStartedWithinGSC

public boolean isStartedWithinGSC()
                           throws RemoteException

Specified by:

isStartedWithinGSC in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

getRuntimeHolder

public RuntimeHolder getRuntimeHolder()
                               throws RemoteException

Specified by:

getRuntimeHolder in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

snapshot

public void snapshot(ITemplatePacket e)
              throws UnusableEntryException,
RemoteException

Specified by:

snapshot in interface IRemoteSpace

Throws:

UnusableEntryException

RemoteException

snapshot

public void snapshot(ITemplatePacket e,
 SpaceContext sc)
              throws UnusableEntryException,
RemoteException

Specified by:

snapshot in interface IRemoteSpace

Throws:

UnusableEntryException

RemoteException

cancel

public void cancel(String entryUID,
 String classname,
 int objectType)
            throws UnknownLeaseException,
RemoteException

Specified by:

cancel in interface IRemoteSpace

Throws:

UnknownLeaseException

RemoteException

renew

public long renew(String entryUID,
 String classname,
 int objectType,
 long duration)
           throws LeaseDeniedException,
UnknownLeaseException,
RemoteException

Specified by:

renew in interface IRemoteSpace

Throws:

LeaseDeniedException

UnknownLeaseException

RemoteException

cancelAll

public Exception[] cancelAll(String[] entryUIDs,
 String[] classnames,
 int[] objectTypes)
                      throws RemoteException

Specified by:

cancelAll in interface IRemoteSpace

Throws:

RemoteException

renewAll

public Object[] renewAll(String[] entryUIDs,
 String[] classnames,
 int[] objectTypes,
 long[] durations)
                  throws RemoteException

Specified by:

renewAll in interface IRemoteSpace

Throws:

RemoteException

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

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

Specified by:

ping in interface IRemoteSpace

Throws:

RemoteException - if a communication error occurs

See Also:

• IRemoteJSpaceAdmin.getState()

getSynchronizationListBatch

public DirectPersistencySyncListBatch getSynchronizationListBatch()
                                                           throws RemoteException

Specified by:

getSynchronizationListBatch in interface IRemoteSpace

Throws:

RemoteException

quiesce

public void quiesce(String description,
 QuiesceToken token,
 boolean readonly)
             throws RemoteException

Specified by:

quiesce in interface IRemoteSpace

Throws:

RemoteException

unquiesce

public void unquiesce()
               throws RemoteException

Specified by:

unquiesce in interface IRemoteSpace

Throws:

RemoteException

getName

public String getName()
               throws RemoteException

Description copied from interface: IRemoteJSpaceAdmin

Returns the Space Name.

 Usage:
        spaceAdmin.getName()
 

Specified by:

getName in interface IRemoteJSpaceAdmin

Specified by:

getName in interface IRemoteSpace

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

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

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

abort

public void abort(TransactionManager parm1,
 Object parm2)
           throws UnknownTransactionException,
RemoteException

Specified by:

abort in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

abort

public void abort(TransactionManager parm1,
 long parm2)
           throws UnknownTransactionException,
RemoteException

Description copied from interface: TransactionParticipant

Requests that the participant roll back any changes for the specified transaction and unlock any resources locked by the transaction. All state associated with the transaction can then be discarded by the participant.

Specified by:

abort in interface TransactionParticipant

Parameters:

parm1 - the manager of the transaction

parm2 - the transaction ID

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

RemoteException - if there is a communication error

commit

public void commit(TransactionManager parm1,
 Object parm2)
            throws UnknownTransactionException,
RemoteException

Specified by:

commit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

commit

public void commit(TransactionManager parm1,
 long parm2)
            throws UnknownTransactionException,
RemoteException

Description copied from interface: TransactionParticipant

Requests that the participant make all of its PREPARED changes for the specified transaction visible outside of the transaction and unlock any resources locked by the transaction. All state associated with the transaction can then be discarded by the participant.

Specified by:

commit in interface TransactionParticipant

Parameters:

parm1 - the manager of the transaction

parm2 - the transaction ID

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

RemoteException - if there is a communication error

commit

public void commit(TransactionManager parm1,
 long parm2,
 int numOfParticipants)
            throws UnknownTransactionException,
RemoteException

Description copied from interface: TransactionParticipant

Requests that the participant make all of its PREPARED changes for the specified transaction visible outside of the transaction and unlock any resources locked by the transaction. All state associated with the transaction can then be discarded by the participant.

Specified by:

commit in interface TransactionParticipant

Parameters:

parm1 - the manager of the transaction

parm2 - the transaction ID

numOfParticipants - the total number of transaction participants this is needed only in commit , since prepareAndCommit is called for single participant

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

RemoteException - if there is a communication error

commit

public void commit(TransactionManager parm1,
 Object parm2,
 int numOfParticipants)
            throws UnknownTransactionException,
RemoteException

Specified by:

commit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public int prepare(TransactionManager parm1,
 Object parm2)
            throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public int prepare(TransactionManager parm1,
 long parm2)
            throws UnknownTransactionException,
RemoteException

Description copied from interface: TransactionParticipant

Requests that the participant prepare itself to commit the transaction, and to vote on the outcome of the transaction. The participant responds with either PREPARED, indicating that it is prepared; ABORT, indicating that it will abort, or NOTCHANGED, indicating that it did not have any state changed by the transaction (i.e., it was read-only). If the response is PREPARED, the participant must wait until it receives a commit or abort call from the transaction manager; it may query the transaction manager if needed as to the state of the transaction. If the response is ABORT, the participant should roll its state back to undo any changes that occurred due to operations performed under the transaction; it can then discard any information about the transaction. If the response is NOTCHANGED, the participant can immediately discard any knowledge of the transaction.

Specified by:

prepare in interface TransactionParticipant

Parameters:

parm1 - the manager of the transaction

parm2 - the transaction ID

Returns:

an int representing this participant's state

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

RemoteException - if there is a communication error

prepare

public int prepare(TransactionManager parm1,
 Object parm2,
 int numOfParticipants)
            throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepareAndCommit

public int prepareAndCommit(TransactionManager parm1,
 Object parm2)
                     throws UnknownTransactionException,
RemoteException

Specified by:

prepareAndCommit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager parm1,
 long parm2,
 boolean parm3)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager parm1,
 Object parm2,
 boolean parm3)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager parm1,
 Object parm2,
 int parm3,
 boolean parm4)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepareAndCommit

public int prepareAndCommit(TransactionManager parm1,
 long parm2)
                     throws UnknownTransactionException,
RemoteException

Description copied from interface: TransactionParticipant

A combination of prepare and commit, which can be used by the manager when there is just one participant left to prepare and all other participants (if any) have responded with NOTCHANGED. The participant's implementation of this method must be equivalent to:

        public int prepareAndCommit(TransactionManager mgr, long id)
            throws UnknownTransactionException, RemoteException
    {
            int result = prepare(mgr, id);
            if (result == PREPARED) {
                commit(mgr, id);
                result = COMMITTED;
        }
            return result;
    }
 

Specified by:

prepareAndCommit in interface TransactionParticipant

Parameters:

parm1 - the manager of the transaction

parm2 - the transaction ID

Returns:

an int representing its state

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

RemoteException - if there is a communication error

See Also:

• TransactionParticipant.prepare(net.jini.core.transaction.server.TransactionManager, long)
• TransactionParticipant.commit(net.jini.core.transaction.server.TransactionManager, long)

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.

getClusterPolicy

public ClusterPolicy getClusterPolicy()
                               throws RemoteException

Returns cluster policy.

Specified by:

getClusterPolicy in interface IRemoteJSpaceAdmin

Returns:

a ClusterPolicy that represents current cluster

Throws:

RemoteException - if a communication error occurs

getAdmin

public Object getAdmin()
                throws RemoteException

Description copied from interface: Administrable

Returns an object that implements whatever administration interfaces are appropriate for the particular service.

Specified by:

getAdmin in interface Administrable

Returns:

an object that implements whatever administration interfaces are appropriate for the particular service.

Throws:

RemoteException

See Also:

• JoinAdmin

getUniqueID

public String getUniqueID()
                   throws RemoteException

Description copied from interface: IRemoteSpace

Generates and returns a unique id

Specified by:

getUniqueID in interface IRemoteSpace

Throws:

RemoteException

getSpaceUuid

public Uuid getSpaceUuid()
                  throws RemoteException

Description copied from interface: IRemoteSpace

returns the universal unique identifier of the remote space

Specified by:

getSpaceUuid in interface IRemoteSpace

Throws:

RemoteException

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

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

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

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)

start

public void start()
           throws RemoteException

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

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

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

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

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 this non-impl 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(IJSpace remoteSpace,
 Object template,
 boolean includeNotifyTemplates,
 int chunkSize)
                          throws RemoteException

Specified by:

spaceCopy in interface IRemoteJSpaceAdmin

Throws:

RemoteException

spaceCopy

public SpaceCopyStatus spaceCopy(IRemoteSpace remoteProxy,
 String remoteSpaceUrl,
 String remoteSpaceName,
 ITemplatePacket template,
 boolean includeNotifyTemplates,
 int chunkSize,
 SpaceContext spaceContext,
 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.

spaceContext - 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

getQueryProcessor

public IQueryProcessor getQueryProcessor()
                                  throws RemoteException

Specified by:

getQueryProcessor in interface IRemoteSpace

Throws:

RemoteException

renewLease

public void renewLease(TransactionManager mgr,
 long id,
 long time)
                throws LeaseDeniedException,
UnknownLeaseException,
RemoteException

Description copied from interface: TransactionParticipant

Notify the transaction participant about transaction lease renewal

Specified by:

renewLease in interface TransactionParticipant

Throws:

LeaseDeniedException

UnknownLeaseException

RemoteException

getSpaceHealthStatus

public SpaceHealthStatus getSpaceHealthStatus()
                                       throws RemoteException

Specified by:

getSpaceHealthStatus in interface IRemoteSpace

Throws:

RemoteException

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.

getServiceProxy

public Object getServiceProxy()
                       throws RemoteException

Description copied from interface: ServiceProxyAccessor

Returns a proxy object for this object. This value should not be null.

Specified by:

getServiceProxy in interface ServiceProxyAccessor

Returns:

a proxy object reference

Throws:

RemoteException

connect

public SpaceConnectResult connect(SpaceConnectRequest request)
                           throws RemoteException

Specified by:

connect in interface IRemoteSpace

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

getReplicationRouterConnectionProxy

public IReplicationConnectionProxy getReplicationRouterConnectionProxy()
                                                                throws RemoteException

Specified by:

getReplicationRouterConnectionProxy in interface IRemoteSpace

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

loadRemoteClass

public Class<?> loadRemoteClass(String className)
                         throws RemoteException,
ClassNotFoundException

Specified by:

loadRemoteClass in interface IRemoteSpace

Throws:

RemoteException

ClassNotFoundException

executeOperation

public <T extends RemoteOperationResult> T executeOperation(RemoteOperationRequest<T> request)
                                                     throws RemoteException

Specified by:

executeOperation in interface RemoteOperationsExecutor

Throws:

RemoteException

executeOperationAsync

public <T extends RemoteOperationResult> T executeOperationAsync(RemoteOperationRequest<T> request)
                                                          throws RemoteException

Specified by:

executeOperationAsync in interface RemoteOperationsExecutor

Throws:

RemoteException

executeOperationOneway

public void executeOperationOneway(RemoteOperationRequest<?> request)
                            throws RemoteException

Specified by:

executeOperationOneway in interface RemoteOperationsExecutor

Throws:

RemoteException

isActive

public boolean isActive()
                 throws RemoteException

Specified by:

isActive in interface RemoteOperationsExecutor

Throws:

RemoteException

isActiveAndNotSuspended

public boolean isActiveAndNotSuspended()
                                throws RemoteException

Specified by:

isActiveAndNotSuspended in interface RemoteOperationsExecutor

Throws:

RemoteException

checkChunkMapGeneration

public ClusterTopology checkChunkMapGeneration(int clientGeneration)

Specified by:

checkChunkMapGeneration in interface RemoteOperationsExecutor

isActiveAsync

public Boolean isActiveAsync()
                      throws RemoteException

Specified by:

isActiveAsync in interface RemoteOperationsExecutor

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

demote

public void demote(long maxSuspendTime,
 TimeUnit unit,
 SpaceContext sc)
            throws DemoteFailedException,
RemoteException

Description copied from interface: IRemoteSpace

Demote leadership and become a backup Space, in the specified operation timeout.

Specified by:

demote in interface IRemoteSpace

Parameters:

maxSuspendTime - The maximum time allowed to be in suspended state, after which the operation is aborted.

unit - The unit of time for the maxSuspendTime parameter.

sc - The SpaceContext for security check in the server side.

Throws:

DemoteFailedException

RemoteException

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

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class RemoteStub<IRemoteSpace>

Throws:

IOException

ClassNotFoundException