Package com.gigaspaces.internal.server.space

Class SpaceImpl

java.lang.Object

com.gigaspaces.internal.service.AbstractGigaSpacesService

com.j_spaces.core.service.AbstractService

com.gigaspaces.internal.server.space.SpaceImpl

All Implemented Interfaces:

GridZoneProvider, JVMInfoProvider, OSInfoProvider, RemoteOperationsExecutor, IRemoteSpace, ILRMIService, NIOInfoProvider, RemoteSecuredService, IInternalRemoteJSpaceAdmin, IRemoteJSpaceAdmin, StatisticsAdmin, Service, ServiceProxyAccessor, Remote, EventListener, Administrable, TransactionConstants, TransactionParticipant, DiscoveryListener

public class SpaceImpl
extends AbstractService
implements IRemoteSpace, IInternalRemoteJSpaceAdmin, DiscoveryListener, TransactionParticipant, StatisticsAdmin

Field Summary

Fields

Modifier and Type	Field	Description
final boolean	_cleanUnusedEmbeddedGlobalXtns
protected static final String	COMPONENT

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

m_adminExporter, m_adminImpl

Fields inherited from class com.gigaspaces.internal.service.AbstractGigaSpacesService

SERVICE_ATTRIBUTE_MODIFY_AWAIT

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
SpaceImpl(String spaceName, String containerName, JSpaceContainerImpl container, SpaceURL url, JSpaceAttributes spaceConfig, Properties customProperties, boolean isSecondary, boolean securityEnabled, LifeCycle lifeCycle)

Method Summary

Modifier and Type	Method	Description
void	abort(TransactionManager mgr, long id)	Requests that the participant roll back any changes for the specified transaction and unlock any resources locked by the transaction.
void	abort(TransactionManager mgr, Object id)
void	abortImpl(TransactionManager mgr, Object id, boolean supportsTwoPhaseReplication, OperationID operationID)
void	addInternalSpaceModeListener(ISpaceModeListener listener)
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.
protected void	AppendInitialLookupAttributes(List<Entry> lookupAttributes)
static void	applyEntryPacketOutFilter(IEntryPacket entryPacket, int modifiers, AbstractProjectionTemplate projectionTemplate)
void	assertAuthorizedForPrivilege(Privilege privilege, SpaceContext spaceContext)
void	assertAuthorizedForType(String typeName, SpaceAuthority.SpacePrivilege privilege, SpaceContext spaceContext)
Object	asyncRead(ITemplatePacket template, Transaction txn, long timeout, boolean ifExists, boolean take, IJSpaceProxyListener listener, SpaceContext sc, boolean returnOnlyUid, int modifiers, IFuture result)
void	beforeOperation(boolean isCheckForStandBy, boolean checkQuiesceMode, SpaceContext sc)
void	beforeOperation(boolean isCheckForStandBy, boolean checkQuiesceMode, SpaceContext sc, Privilege opPrivilegeRequired)
void	beforeTypeOperation(boolean isCheckForStandBy, SpaceContext sc, Privilege privilege, String className)
void	beginPacketOperation(boolean isCheckForStandBy, SpaceContext sc, Privilege privilege, ITransportPacket packet)
void	cancel(String entryUID, String classname, int objectType)
void	cancel(String entryUID, String classname, int objectType, boolean isFromGateway)
Exception[]	cancelAll(String[] entryUIDs, String[] classnames, int[] objectTypes)
void	changeSpaceState(int state, boolean electable, boolean replicable)	Change space state to given state - lookup attributes are updated as well
ClusterTopology	checkChunkMapGeneration(int clientGeneration)
void	checkPacketAccessPrivileges(SpaceContext sc, Privilege privilege, ITransportPacket packet)	Check if a user's has sufficient privileges to perform this operation.
void	cleanOnDestroy()
Pair<Integer,SingleExplainPlan>	clear(ITemplatePacket template, Transaction txn, int modifiers, SpaceContext sc)
void	clearBroadcastTables()
void	closeServerIterator(UUID uuid)
void	commit(TransactionManager mgr, long id)	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 mgr, long id, 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 mgr, Object id)
void	commit(TransactionManager mgr, Object id, int numOfParticipants)
void	commitImpl(TransactionManager mgr, Object id, int numOfParticipants, boolean supportsTwoPhaseReplication, OperationID operationID, boolean mayBeFromReplication)
SpaceConnectResult	connect(SpaceConnectRequest request)
Pair<Integer,SingleExplainPlan>	count(ITemplatePacket template, Transaction txn, SpaceContext sc, int modifiers)
int	countIncomingConnections()
int	countTransactions(int type, int status)
protected SpaceProxyImpl	createProxy(boolean isClustered, boolean useEmbeddedCredentials)
ServerTransaction	createServerTransaction(TransactionManager mgr, Object id, int numOfParticipants)
SpaceSettings	createSpaceSettingsWithNewClusterTopology(ClusterTopology newTopology)
void	demote(long maxSuspendTime, TimeUnit unit, SpaceContext sc)	Demote leadership and become a backup Space, in the specified operation timeout.
void	directDropCLassForAllProxies(String className)
void	disableLRMIMonitoring()	Disabled lrmi monitoring (gigaspaces internal remoting layer).
void	disableStub()	disable remote.
void	discarded(DiscoveryEvent event)	Called when one or more lookup service registrars has been discarded.
void	discovered(DiscoveryEvent event)	Called when one or more lookup service registrars has been discovered.
void	dropClass(String className, SpaceContext sc)	Drop all Class entries and all its templates from the space.
Map<UUID,CompoundDurableTaskData>	durableTasks()
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.
SpaceResponseInfo	executeAction(SystemTask systemTask)
Object	executeDurableTask(UUID uuid, SpaceContext spaceContext)
<T extends RemoteOperationResult> T	executeOperation(RemoteOperationRequest<T> request)
<T extends RemoteOperationResult> T	executeOperationAsync(RemoteOperationRequest<T> request)
void	executeOperationOneway(RemoteOperationRequest<?> request)
Object	executeTask(SpaceTask task, Transaction tx, SpaceContext sc, boolean newRouter)
static String	extractContainerName(String fullName)
static String	extractInstanceId(String fullName)
static String	extractInstanceIdFromContainerName(String containerName)
LRMIMonitoringDetails	fetchLRMIMonitoringDetails()	Return lrmi (gigaspaces internal remoting layer) services monitoring details.
protected String	filterUnicastHosts(String configuredHosts)	Applies partition-based LUS selection using modulo distribution.
int	flushRedoLogToStorage()	Flush redo-log packets from memory to underlying storage.
void	forceMoveToPrimary()	Forcefully make this space to be primary
static Object	fromBytes(byte[] bytes, List<ClassLoader> classLoaders)
Object	getAdmin()	Return service admin proxy
AttributeStore	getAttributeStore()
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.
ClusterFailureDetector	getClusterFailureDetector()
SpaceClusterInfo	getClusterInfo()
ClusterPolicy	getClusterPolicy()	Return the present ClusterPolicy objects.
SpaceConfig	getConfig()	Returns SpaceConfig of this space.
SpaceConfigReader	getConfigReader()
List<ITransportConnection>	getConnectionsInfo()
JSpaceContainerImpl	getContainer()
String	getContainerName()
long	getCurrentTimestamp()
Properties	getCustomProperties()
String	getDeployPath()	Returns the deploy path of this space instance, when deployed in the service grid.
DirectPersistencyRecoveryHelper	getDirectPersistencyRecoveryHelper()
SpaceEngine	getEngine()
Map<Object,EntryTieredMetaData>	getEntriesTieredMetaDataByIds(String typeName, Object[] ids)
StatisticsHolder	getHolder()
String	getInstanceId()
JSpaceAttributes	getJspaceAttr()
JVMDetails	getJVMDetails()
JVMStatistics	getJVMStatistics()
LeaderSelectorHandler	getLeaderSelector()
Map<String,LocalCacheDetails>	getLocalCacheDetails()
SpaceHealthStatus	getLocalSpaceHealthStatus()
Map<String,LocalViewDetails>	getLocalViewDetails()
List<UnderTxnLockedObject>	getLockedObjects(Transaction txn)	getLockedObjects is called by the GUI.
Map<String,Object>	getMetricSnapshots(Collection<String> prefixes)
MVCCEntryMetaData	getMVCCDirtyEntryMetaDataUnderTransaction(String typeName, Object id, long transactionId)
ArrayList<MVCCEntryMetaData>	getMVCCEntryMetaData(String typeName, Object id)
String	getName()	Returns the Space Name.
ServerIteratorAnswerHolder	getNextBatchFromServerIterator(ITemplatePacket template, SpaceContext sc, int modifiers, ServerIteratorRequestInfo serverIteratorRequestInfo)
NIODetails	getNIODetails()	Returns the transport configuration.
NIOStatistics	getNIOStatistics()	Returns the transport statistics.
String	getNodeName()
org.slf4j.Logger	getOperationLogger()
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
int	getPartitionId()
int	getPartitionIdOneBased()
PrimarySpaceModeListeners	getPrimarySpaceModeListeners()
String	getPuName()
IQueryProcessor	getQueryProcessor()
QuiesceHandler	getQuiesceHandler()
AtomicBoolean	getRecoveryIndicator()
String	getReplicationDump()
IReplicationConnectionProxy	getReplicationRouterConnectionProxy()
ReplicationStatistics	getReplicationStatistics()
Object[]	getReplicationStatus()	return the replication status of all my replication group returns an array of remote member names and an array of replication status to them.
RuntimeHolder	getRuntimeHolder()
SpaceRuntimeInfo	getRuntimeInfo()	Returns SpaceRuntimeInfo.
SpaceRuntimeInfo	getRuntimeInfo(String className)	Returns SpaceRuntimeInfo for specific class name and its subclasses.
String	getServiceName()
SpaceProxyImpl	getServiceProxy()	Returns a proxy object for this object.
protected String	getServiceTypeDescription()
IDirectSpaceProxy	getSingleProxy()	Return the internal instance of embedded not-clustered space proxy.
LinkedList<ISpaceComponentsHandler>	getSpaceComponentHandlers()	Create a list of all space component handlers
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.
IJSpace	getSpaceProxy()	Return the internal instance of space proxy.
IRemoteSpace	getSpaceStub()
Uuid	getSpaceUuid()	returns the universal unique identifier of the remote space
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.
IStubHandler	getStubHandler()
DirectPersistencySyncListBatch	getSynchronizationListBatch()
protected IJSpace	getTaskProxy()
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
SpaceURL	getURL()	Returns the SpaceURL object which initialized that specific space instance.
ZKCollocatedClientConfig	getZkConfig()
String[]	getZones()
ZookeeperLastPrimaryHandler	getZookeeperLastPrimaryHandler()
void	initAndRecoverFromDataStorage(boolean isWarm)	Initialize main space components
void	internalClean(boolean isInternalUse, boolean isRestart, boolean isWarmInit)
boolean	isAborted()
boolean	isActive()
boolean	isActiveAndNotSuspended()
Boolean	isActiveAsync()
boolean	isBackup()
boolean	isClusteredSpace()
boolean	isEmbedded()
boolean	isLocalCache()
boolean	isMvccEnabled()
boolean	isPrimary()
boolean	isPrivate()
boolean	isRecovering()
boolean	isSecuredSpace()
boolean	isStartedWithinGSC()
boolean	isStatisticsAvailable()	Checks if space statistics is available.
void	loadDynamicCLassDef(ExecuteTaskSpaceOperationRequest request)
Class<?>	loadRemoteClass(String className)
SecurityContext	login(SecurityContext securityContext)	Login to a secured service using the provided SecurityContext
GSEventRegistration	notify(ITemplatePacket template, Transaction txn, long lease, SpaceContext sc, NotifyInfo info)
void	ping()	Ping to space to see if alive.
int	prepare(TransactionManager mgr, long id)	Requests that the participant prepare itself to commit the transaction, and to vote on the outcome of the transaction.
Object	prepare(TransactionManager mgr, long id, boolean needClusteredProxy)
int	prepare(TransactionManager mgr, Object id)
Object	prepare(TransactionManager mgr, Object parm2, boolean needClusteredProxy)
int	prepare(TransactionManager mgr, Object id, int numOfParticipants)
Object	prepare(TransactionManager mgr, Object parm2, int numOfParticipants, boolean needClusteredProxy)
int	prepareAndCommit(TransactionManager mgr, long id)	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 mgr, Object id)
int	prepareAndCommitImpl(TransactionManager mgr, Object id, OperationID operationID)
boolean	pullBroadcastTables()
void	quiesce(String description, QuiesceToken token, boolean readonly)
AnswerPacket	read(ITemplatePacket template, Transaction txn, long timeout, boolean ifExists, boolean take, IJSpaceProxyListener listener, SpaceContext sc, boolean returnOnlyUid, int modifiers)
IEntryPacket[]	readByIds(ITemplatePacket template, Transaction txn, boolean take, SpaceContext spaceContext, int modifiers)
IEntryPacket[]	readMultiple(ITemplatePacket template, Transaction txn, boolean take, int maxEntries, SpaceContext sc, boolean returnOnlyUid, int modifiers)
AnswerHolder	readMultiple(ITemplatePacket template, Transaction txn, boolean take, int maxEntries, SpaceContext sc, boolean returnOnlyUid, int modifiers, int minEntries, long timeout, boolean isIfExist)
AnswerHolder	readNew(ITemplatePacket template, Transaction txn, long timeout, boolean ifExists, boolean take, IJSpaceProxyListener listener, SpaceContext sc, boolean returnOnlyUid, int modifiers)
void	registerToClusterInfoChangedEvent(IClusterInfoChangedListener listener)
void	removeClusterInfoChangedListener(IClusterInfoChangedListener listener)
void	removeInternalSpaceModeListener(ISpaceModeListener listener)
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)
long	renew(String entryUID, String classname, int objectType, long duration, boolean isFromGateway)
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	renewServerIteratorLease(UUID uuid)
void	restart()	Restarts the space.
boolean	restartLeaderSelectorHandler()
void	restoreDurableTasks()
boolean	runDurableTask(Map<String,byte[]> classes, DistributedSpaceTask distributedSpaceTask, UUID uuid, SpaceContext spaceContext, String name, String description, boolean immediatelyStart)
void	runGc()
void	setClusterConfigFile(byte[] config)	set the cluster configuration according to the given byte representation of the configuration file.
static void	setConfig(String spaceName, String containerName, JSpaceAttributes config, String spaceFileURL)
void	setStatisticsSamplingRate(long rate)	Set statistics sampling rate.
void	shutdown()	Shutdown this space, do not destroy it.
void	shutdown(boolean isDestroy, boolean shutdowContainer)	Attempt to shutdown this service .
void	snapshot(ITemplatePacket template)
void	snapshot(ITemplatePacket template, SpaceContext sc)
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	startInternal()
void	stop()	Attempt to stop this space.
void	stopInternal()
boolean	terminateDurableTask(UUID uuid)
String	toString()
void	unquiesce()
void	unregister()
AnswerPacket	update(IEntryPacket entry, Transaction txn, long lease, long timeout, SpaceContext sc, int modifiers, boolean newRouter)
void	updateClusterInfo()	trigger read of chunks map from zk and update clusterInfo
void	updateXmlConfigEntry(String configEntry, String configValue)	Update specified configuration entry.
boolean	useZooKeeper()
void	waitForDrain(long timeoutMs, long minTimeToWait, boolean isBackupOnly, org.slf4j.Logger logger)
void	waitForZkUpdate(Step step, String key, Status status)
WriteEntriesResult	write(IEntryPacket[] entries, Transaction txn, long lease, long[] leases, SpaceContext sc, long timeout, int modifiers, boolean newRouter)
WriteEntryResult	write(IEntryPacket entry, Transaction txn, long lease, int modifiers, boolean fromReplication, SpaceContext sc)
LeaseContext<?>[]	writeOld(IEntryPacket[] entries, Transaction txn, long lease, long[] leases, SpaceContext sc, int modifiers)
String	zkClass(String uuid, String classname)
String	zkClassName(String uuid, String classname)

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

registerLookupService

Methods inherited from class com.gigaspaces.internal.service.AbstractGigaSpacesService

addLookupAttributes, addLookupAttributes, getExporter, getJoinManager, getLifeCycle, getUuid, modifyLookupAttributes, registerLookupService, unregisterFromLookupService

Methods inherited from class java.lang.Object

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

Field Details

COMPONENT

protected static final String COMPONENT

See Also:

• Constant Field Values

_cleanUnusedEmbeddedGlobalXtns

public final boolean _cleanUnusedEmbeddedGlobalXtns

Constructor Details

SpaceImpl

public SpaceImpl(String spaceName,
 String containerName,
 JSpaceContainerImpl container,
 SpaceURL url,
 JSpaceAttributes spaceConfig,
 Properties customProperties,
 boolean isSecondary,
 boolean securityEnabled,
 LifeCycle lifeCycle)
          throws CreateException,
RemoteException

Throws:

CreateException

RemoteException

Method Details

runDurableTask

public boolean runDurableTask(Map<String,byte[]> classes,
 DistributedSpaceTask distributedSpaceTask,
 UUID uuid,
 SpaceContext spaceContext,
 String name,
 String description,
 boolean immediatelyStart)
                       throws RemoteException

Throws:

RemoteException

executeDurableTask

public Object executeDurableTask(UUID uuid,
 SpaceContext spaceContext)
                          throws Exception

Throws:

Exception

durableTasks

public Map<UUID,CompoundDurableTaskData> durableTasks()

zkClassName

public String zkClassName(String uuid,
 String classname)

zkClass

public String zkClass(String uuid,
 String classname)

fromBytes

public static Object fromBytes(byte[] bytes,
 List<ClassLoader> classLoaders)

terminateDurableTask

public boolean terminateDurableTask(UUID uuid)

getZkConfig

public ZKCollocatedClientConfig getZkConfig()

getZookeeperLastPrimaryHandler

public ZookeeperLastPrimaryHandler getZookeeperLastPrimaryHandler()

getContainerName

public String getContainerName()

Specified by:

getContainerName in class AbstractService

getInstanceId

public String getInstanceId()

getNodeName

public String getNodeName()

getURL

public SpaceURL getURL()

Returns the SpaceURL object which initialized that specific space instance. Note that the SpaceURL object contains important information on the space and container configuration/setup such as the space url used, the space/container/cluster schema used and other attributes.

The IJSpaceContainer keeps also its reference of the SpaceURL which launched the container.

Returns:

SpaceURL Returns the SpaceURL object which initialized that specific space instance.

getCustomProperties

public Properties getCustomProperties()

getJspaceAttr

public JSpaceAttributes getJspaceAttr()

getContainer

public JSpaceContainerImpl getContainer()

getOperationLogger

public org.slf4j.Logger getOperationLogger()

isPrivate

public boolean isPrivate()

getServiceName

public String getServiceName()

Specified by:

getServiceName in interface ILRMIService

Specified by:

getServiceName in class AbstractGigaSpacesService

getServiceTypeDescription

protected String getServiceTypeDescription()

Overrides:

getServiceTypeDescription in class AbstractGigaSpacesService

getAdmin

public Object getAdmin()

Description copied from class: AbstractService

Return service admin proxy

Specified by:

getAdmin in interface Administrable

Overrides:

getAdmin in class AbstractService

Returns:

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

See Also:

• JoinAdmin

extractInstanceIdFromContainerName

public static String extractInstanceIdFromContainerName(String containerName)

extractContainerName

public static String extractContainerName(String fullName)

extractInstanceId

public static String extractInstanceId(String fullName)

isSecuredSpace

public boolean isSecuredSpace()

getEngine

public SpaceEngine getEngine()

getQuiesceHandler

public QuiesceHandler getQuiesceHandler()

getDirectPersistencyRecoveryHelper

public DirectPersistencyRecoveryHelper getDirectPersistencyRecoveryHelper()

beforeOperation

public void beforeOperation(boolean isCheckForStandBy,
 boolean checkQuiesceMode,
 SpaceContext sc)
                     throws RemoteException

Throws:

RemoteException

beforeOperation

public void beforeOperation(boolean isCheckForStandBy,
 boolean checkQuiesceMode,
 SpaceContext sc,
 Privilege opPrivilegeRequired)
                     throws RemoteException

Throws:

RemoteException

beforeTypeOperation

public void beforeTypeOperation(boolean isCheckForStandBy,
 SpaceContext sc,
 Privilege privilege,
 String className)
                         throws RemoteException

Throws:

RemoteException

beginPacketOperation

public void beginPacketOperation(boolean isCheckForStandBy,
 SpaceContext sc,
 Privilege privilege,
 ITransportPacket packet)
                          throws RemoteException

Throws:

RemoteException

checkPacketAccessPrivileges

public void checkPacketAccessPrivileges(SpaceContext sc,
 Privilege privilege,
 ITransportPacket packet)

Check if a user's has sufficient privileges to perform this operation.

Parameters:

sc - Holds the security context

privilege - The privilege required to perform this operation.

packet - The packet applied to this operation (can be null).

internalClean

public void internalClean(boolean isInternalUse,
 boolean isRestart,
 boolean isWarmInit)

cleanOnDestroy

public void cleanOnDestroy()

getPrimarySpaceModeListeners

public PrimarySpaceModeListeners getPrimarySpaceModeListeners()

getPartitionIdOneBased

public int getPartitionIdOneBased()

getPartitionId

public int getPartitionId()

registerToClusterInfoChangedEvent

public void registerToClusterInfoChangedEvent(IClusterInfoChangedListener listener)

isMvccEnabled

public boolean isMvccEnabled()

removeClusterInfoChangedListener

public void removeClusterInfoChangedListener(IClusterInfoChangedListener listener)

getSpaceProxy

public IJSpace getSpaceProxy()
                      throws RemoteException

Return the internal instance of space proxy.

Returns:

If cluster policy contains LB or FO, then return clustered proxy,otherwise regular proxy

Throws:

RemoteException

getSingleProxy

public IDirectSpaceProxy getSingleProxy()
                                 throws RemoteException

Return the internal instance of embedded not-clustered space proxy.

Throws:

RemoteException

getTaskProxy

protected IJSpace getTaskProxy()
                        throws RemoteException

Throws:

RemoteException

createProxy

protected SpaceProxyImpl createProxy(boolean isClustered,
 boolean useEmbeddedCredentials)
                              throws RemoteException

Throws:

RemoteException

createSpaceSettingsWithNewClusterTopology

public SpaceSettings createSpaceSettingsWithNewClusterTopology(ClusterTopology newTopology)

isClusteredSpace

public boolean isClusteredSpace()

getSpaceStub

public IRemoteSpace getSpaceStub()
                          throws RemoteException

Throws:

RemoteException

toString

public String toString()

Overrides:

toString in class Object

setConfig

public static void setConfig(String spaceName,
 String containerName,
 JSpaceAttributes config,
 String spaceFileURL)
                      throws RemoteException

Throws:

RemoteException

getConfigReader

public SpaceConfigReader getConfigReader()

getSpaceUuid

public Uuid getSpaceUuid()

Description copied from interface: IRemoteSpace

returns the universal unique identifier of the remote space

Specified by:

getSpaceUuid in interface IRemoteSpace

shutdown

public void shutdown()
              throws RemoteException

Shutdown this space, do not destroy it.

Specified by:

shutdown in class AbstractService

Throws:

RemoteException

See Also:

• ServiceAdminImpl.destroy()

shutdown

public void shutdown(boolean isDestroy,
 boolean shutdowContainer)
              throws RemoteException

Attempt to shutdown this service .

Parameters:

isDestroy - specify that space should be destroyed.

shutdowContainer - If has true value and space container contains one space, it will be also shutdown.

Throws:

RemoteException

unregister

public void unregister()
                throws RemoteException

Throws:

RemoteException

loadDynamicCLassDef

public void loadDynamicCLassDef(ExecuteTaskSpaceOperationRequest request)

restoreDurableTasks

public void restoreDurableTasks()

initAndRecoverFromDataStorage

public void initAndRecoverFromDataStorage(boolean isWarm)
                                   throws RemoteException,
CreateException,
SpaceComponentsInitializeException

Initialize main space components

Parameters:

isWarm - if set to true - the space will recover from database

Throws:

RemoteException

CreateException

SpaceComponentsInitializeException

useZooKeeper

public boolean useZooKeeper()

restartLeaderSelectorHandler

public boolean restartLeaderSelectorHandler()

getLeaderSelector

public LeaderSelectorHandler getLeaderSelector()

getClusterFailureDetector

public ClusterFailureDetector getClusterFailureDetector()

updateXmlConfigEntry

public void updateXmlConfigEntry(String configEntry,
 String configValue)
                          throws IOException

Update specified configuration entry.

Throws:

IOException

createServerTransaction

public ServerTransaction createServerTransaction(TransactionManager mgr,
 Object id,
 int numOfParticipants)

changeSpaceState

public void changeSpaceState(int state,
 boolean electable,
 boolean replicable)

Change space state to given state - lookup attributes are updated as well

getSpaceComponentHandlers

public LinkedList<ISpaceComponentsHandler> getSpaceComponentHandlers()

Create a list of all space component handlers

Returns:

list of all space component handlers

getLocalSpaceHealthStatus

public SpaceHealthStatus getLocalSpaceHealthStatus()

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.

addInternalSpaceModeListener

public void addInternalSpaceModeListener(ISpaceModeListener listener)

removeInternalSpaceModeListener

public void removeInternalSpaceModeListener(ISpaceModeListener listener)

getServiceProxy

public SpaceProxyImpl 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

isAborted

public boolean isAborted()

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()

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

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in interface IRemoteSpace

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()

getSpaceHealthStatus

public SpaceHealthStatus getSpaceHealthStatus()
                                       throws RemoteException

Specified by:

getSpaceHealthStatus in interface IRemoteSpace

Throws:

RemoteException

getQueryProcessor

public IQueryProcessor getQueryProcessor()

Specified by:

getQueryProcessor in interface IRemoteSpace

getStubHandler

public IStubHandler getStubHandler()

getUniqueID

public String getUniqueID()
                   throws RemoteException

Generates and returns a unique id

Specified by:

getUniqueID in interface IRemoteSpace

Throws:

RemoteException

loadRemoteClass

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

Specified by:

loadRemoteClass in interface IRemoteSpace

Throws:

ClassNotFoundException

executeAction

public SpaceResponseInfo executeAction(SystemTask systemTask)

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

isActiveAsync

public Boolean isActiveAsync()
                      throws RemoteException

Specified by:

isActiveAsync in interface RemoteOperationsExecutor

Throws:

RemoteException

checkChunkMapGeneration

public ClusterTopology checkChunkMapGeneration(int clientGeneration)

Specified by:

checkChunkMapGeneration in interface RemoteOperationsExecutor

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

write

public WriteEntryResult write(IEntryPacket entry,
 Transaction txn,
 long lease,
 int modifiers,
 boolean fromReplication,
 SpaceContext sc)
                       throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

writeOld

public LeaseContext<?>[] writeOld(IEntryPacket[] entries,
 Transaction txn,
 long lease,
 long[] leases,
 SpaceContext sc,
 int modifiers)
                           throws TransactionException,
UnknownTypesException,
RemoteException

Throws:

TransactionException

UnknownTypesException

RemoteException

write

public WriteEntriesResult write(IEntryPacket[] entries,
 Transaction txn,
 long lease,
 long[] leases,
 SpaceContext sc,
 long timeout,
 int modifiers,
 boolean newRouter)
                         throws TransactionException,
UnknownTypesException,
RemoteException

Throws:

TransactionException

UnknownTypesException

RemoteException

update

public AnswerPacket update(IEntryPacket entry,
 Transaction txn,
 long lease,
 long timeout,
 SpaceContext sc,
 int modifiers,
 boolean newRouter)
                    throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

count

public Pair<Integer,SingleExplainPlan> count(ITemplatePacket template,
 Transaction txn,
 SpaceContext sc,
 int modifiers)
                                      throws UnusableEntryException,
UnknownTypeException,
TransactionException,
RemoteException

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

clear

public Pair<Integer,SingleExplainPlan> clear(ITemplatePacket template,
 Transaction txn,
 int modifiers,
 SpaceContext sc)
                                      throws UnusableEntryException,
UnknownTypeException,
TransactionException,
RemoteException

Throws:

UnusableEntryException

UnknownTypeException

TransactionException

RemoteException

readNew

public AnswerHolder readNew(ITemplatePacket template,
 Transaction txn,
 long timeout,
 boolean ifExists,
 boolean take,
 IJSpaceProxyListener listener,
 SpaceContext sc,
 boolean returnOnlyUid,
 int modifiers)
                     throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

read

public AnswerPacket read(ITemplatePacket template,
 Transaction txn,
 long timeout,
 boolean ifExists,
 boolean take,
 IJSpaceProxyListener listener,
 SpaceContext sc,
 boolean returnOnlyUid,
 int modifiers)
                  throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

asyncRead

public Object asyncRead(ITemplatePacket template,
 Transaction txn,
 long timeout,
 boolean ifExists,
 boolean take,
 IJSpaceProxyListener listener,
 SpaceContext sc,
 boolean returnOnlyUid,
 int modifiers,
 IFuture result)
                 throws UnusableEntryException,
TransactionException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

UnusableEntryException

TransactionException

UnknownTypeException

RemoteException

InterruptedException

getNextBatchFromServerIterator

public ServerIteratorAnswerHolder getNextBatchFromServerIterator(ITemplatePacket template,
 SpaceContext sc,
 int modifiers,
 ServerIteratorRequestInfo serverIteratorRequestInfo)
                                                          throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

closeServerIterator

public void closeServerIterator(UUID uuid)

renewServerIteratorLease

public void renewServerIteratorLease(UUID uuid)

readMultiple

public IEntryPacket[] readMultiple(ITemplatePacket template,
 Transaction txn,
 boolean take,
 int maxEntries,
 SpaceContext sc,
 boolean returnOnlyUid,
 int modifiers)
                            throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

readMultiple

public AnswerHolder readMultiple(ITemplatePacket template,
 Transaction txn,
 boolean take,
 int maxEntries,
 SpaceContext sc,
 boolean returnOnlyUid,
 int modifiers,
 int minEntries,
 long timeout,
 boolean isIfExist)
                          throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

applyEntryPacketOutFilter

public static void applyEntryPacketOutFilter(IEntryPacket entryPacket,
 int modifiers,
 AbstractProjectionTemplate projectionTemplate)

readByIds

public IEntryPacket[] readByIds(ITemplatePacket template,
 Transaction txn,
 boolean take,
 SpaceContext spaceContext,
 int modifiers)
                         throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

getEntriesTieredMetaDataByIds

public Map<Object,EntryTieredMetaData> getEntriesTieredMetaDataByIds(String typeName,
 Object[] ids)
                                                              throws Exception

Throws:

Exception

getMVCCEntryMetaData

public ArrayList<MVCCEntryMetaData> getMVCCEntryMetaData(String typeName,
 Object id)

getMVCCDirtyEntryMetaDataUnderTransaction

public MVCCEntryMetaData getMVCCDirtyEntryMetaDataUnderTransaction(String typeName,
 Object id,
 long transactionId)

notify

public GSEventRegistration notify(ITemplatePacket template,
 Transaction txn,
 long lease,
 SpaceContext sc,
 NotifyInfo info)
                           throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

snapshot

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

Specified by:

snapshot in interface IRemoteSpace

Throws:

UnusableEntryException

RemoteException

snapshot

public void snapshot(ITemplatePacket template)
              throws UnusableEntryException,
RemoteException

Specified by:

snapshot in interface IRemoteSpace

Throws:

UnusableEntryException

RemoteException

cancel

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

Throws:

UnknownLeaseException

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,
 boolean isFromGateway)
           throws UnknownLeaseException,
RemoteException

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

abort

public void abort(TransactionManager mgr,
 long id)
           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:

mgr - the manager of the transaction

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

abort

public void abort(TransactionManager mgr,
 Object id)
           throws UnknownTransactionException,
RemoteException

Specified by:

abort in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

abortImpl

public void abortImpl(TransactionManager mgr,
 Object id,
 boolean supportsTwoPhaseReplication,
 OperationID operationID)
               throws RemoteException,
UnknownTransactionException

Throws:

RemoteException

UnknownTransactionException

commit

public void commit(TransactionManager mgr,
 long id)
            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:

mgr - the manager of the transaction

id - 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 mgr,
 Object id)
            throws UnknownTransactionException,
RemoteException

Specified by:

commit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

commit

public void commit(TransactionManager mgr,
 long id,
 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:

mgr - the manager of the transaction

id - 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 mgr,
 Object id,
 int numOfParticipants)
            throws UnknownTransactionException,
RemoteException

Specified by:

commit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

commitImpl

public void commitImpl(TransactionManager mgr,
 Object id,
 int numOfParticipants,
 boolean supportsTwoPhaseReplication,
 OperationID operationID,
 boolean mayBeFromReplication)
                throws RemoteException,
UnknownTransactionException

Throws:

RemoteException

UnknownTransactionException

prepare

public int prepare(TransactionManager mgr,
 long id)
            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:

mgr - the manager of the transaction

id - 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 mgr,
 Object id)
            throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public int prepare(TransactionManager mgr,
 Object id,
 int numOfParticipants)
            throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager mgr,
 long id,
 boolean needClusteredProxy)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager mgr,
 Object parm2,
 boolean needClusteredProxy)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepare

public Object prepare(TransactionManager mgr,
 Object parm2,
 int numOfParticipants,
 boolean needClusteredProxy)
               throws UnknownTransactionException,
RemoteException

Specified by:

prepare in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepareAndCommit

public int prepareAndCommit(TransactionManager mgr,
 long id)
                     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:

mgr - the manager of the transaction

id - 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)

prepareAndCommit

public int prepareAndCommit(TransactionManager mgr,
 Object id)
                     throws UnknownTransactionException,
RemoteException

Specified by:

prepareAndCommit in interface IRemoteSpace

Throws:

UnknownTransactionException

RemoteException

prepareAndCommitImpl

public int prepareAndCommitImpl(TransactionManager mgr,
 Object id,
 OperationID operationID)
                         throws RemoteException,
UnknownTransactionException

Throws:

RemoteException

UnknownTransactionException

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

executeTask

public Object executeTask(SpaceTask task,
 Transaction tx,
 SpaceContext sc,
 boolean newRouter)
                   throws RemoteException,
ExecutionException

Throws:

RemoteException

ExecutionException

getReplicationRouterConnectionProxy

public IReplicationConnectionProxy getReplicationRouterConnectionProxy()
                                                                throws RemoteException

Specified by:

getReplicationRouterConnectionProxy in interface IRemoteSpace

Throws:

RemoteException

getNIODetails

public NIODetails getNIODetails()

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

getNIOStatistics

public NIOStatistics getNIOStatistics()

Description copied from interface: NIOInfoProvider

Returns the transport statistics.

Specified by:

getNIOStatistics in interface NIOInfoProvider

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()

Specified by:

getCurrentTimestamp in interface OSInfoProvider

getOSDetails

public OSDetails getOSDetails()

Specified by:

getOSDetails in interface OSInfoProvider

getOSStatistics

public OSStatistics getOSStatistics()

Specified by:

getOSStatistics in interface OSInfoProvider

getJVMDetails

public JVMDetails getJVMDetails()

Specified by:

getJVMDetails in interface JVMInfoProvider

getJVMStatistics

public JVMStatistics getJVMStatistics()

Specified by:

getJVMStatistics in interface JVMInfoProvider

runGc

public void runGc()

Specified by:

runGc in interface JVMInfoProvider

getZones

public String[] getZones()

Specified by:

getZones in interface GridZoneProvider

isStatisticsAvailable

public boolean isStatisticsAvailable()

Description copied from interface: StatisticsAdmin

Checks if space statistics is available.

Specified by:

isStatisticsAvailable in interface StatisticsAdmin

Returns:

true if space statistics is available

getStatisticsStringArray

public String[] getStatisticsStringArray()
                                  throws StatisticsNotAvailable

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

getStatisticsSamplingRate

public long getStatisticsSamplingRate()
                               throws StatisticsNotAvailable

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

setStatisticsSamplingRate

public void setStatisticsSamplingRate(long rate)
                               throws StatisticsNotAvailable

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

getStatistics

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

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

getStatistics

public StatisticsContext getStatistics(int operationCode)
                                throws StatisticsNotAvailable

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

See Also:

• FilterOperationCodes

getStatistics

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

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

getHolder

public StatisticsHolder getHolder()

Specified by:

getHolder in interface StatisticsAdmin

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

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()

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.

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

startInternal

public void startInternal()
                   throws RemoteException

Throws:

RemoteException

filterUnicastHosts

protected String filterUnicastHosts(String configuredHosts)

Applies partition-based LUS selection using modulo distribution.

Each partition registers with K out of N LUS instances (configurable via com.gs.lus.registration.count). When K=0 (default) or K >= N, all LUS instances are used — backward compatible.

Overrides:

filterUnicastHosts in class AbstractService

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

stopInternal

public void stopInternal()
                  throws RemoteException

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.

getSpaceInstanceRemoteClassLoaderInfo

public SpaceInstanceRemoteClassLoaderInfo getSpaceInstanceRemoteClassLoaderInfo()

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

getReplicationStatus

public Object[] getReplicationStatus()
                              throws RemoteException

return the replication status of all my replication group returns an array of remote member names and an array of replication status to them.

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

getClusterPolicy

public ClusterPolicy getClusterPolicy()

Description copied from interface: IRemoteJSpaceAdmin

Return the present ClusterPolicy objects.

Specified by:

getClusterPolicy in interface IRemoteJSpaceAdmin

Returns:

a ClusterPolicy that represents current cluster

getClusterInfo

public SpaceClusterInfo getClusterInfo()

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

dropClass

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

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.

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.

directDropCLassForAllProxies

public void directDropCLassForAllProxies(String className)

getState

public int getState()

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.

See Also:

• ISpaceState

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

getRuntimeHolder

public RuntimeHolder getRuntimeHolder()
                               throws RemoteException

Specified by:

getRuntimeHolder in interface IInternalRemoteJSpaceAdmin

Throws:

RemoteException

isStartedWithinGSC

public boolean isStartedWithinGSC()

Specified by:

isStartedWithinGSC in interface IInternalRemoteJSpaceAdmin

getDeployPath

public String getDeployPath()

Returns the deploy path of this space instance, when deployed in the service grid. NOTE: When not deployed in the service grid, this method may return null.

spaceCopy

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

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.

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

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

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()

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.

isPrimary

public boolean isPrimary()

isBackup

public boolean isBackup()

addSpaceModeListener

public SpaceMode addSpaceModeListener(ISpaceModeListener listener)

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.

See Also:

• ISpaceModeListener
• SpaceMode

removeSpaceModeListener

public void removeSpaceModeListener(ISpaceModeListener listener)

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.

See Also:

• IInternalRemoteJSpaceAdmin.addSpaceModeListener(ISpaceModeListener)

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

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()

Specified by:

getReplicationDump in interface IInternalRemoteJSpaceAdmin

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

assertAuthorizedForType

public void assertAuthorizedForType(String typeName,
 SpaceAuthority.SpacePrivilege privilege,
 SpaceContext spaceContext)

assertAuthorizedForPrivilege

public void assertAuthorizedForPrivilege(Privilege privilege,
 SpaceContext spaceContext)

isRecovering

public boolean isRecovering()

getRecoveryIndicator

public AtomicBoolean getRecoveryIndicator()

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

isLocalCache

public boolean isLocalCache()

spaceCopy

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

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.

spaceCopy

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

Specified by:

spaceCopy in interface IRemoteJSpaceAdmin

discarded

public void discarded(DiscoveryEvent event)

Description copied from interface: DiscoveryListener

Called when one or more lookup service registrars has been discarded. The method should return quickly; e.g., it should not make remote calls.

Specified by:

discarded in interface DiscoveryListener

Parameters:

event - the event that describes the discarded registrars

discovered

public void discovered(DiscoveryEvent event)

Description copied from interface: DiscoveryListener

Called when one or more lookup service registrars has been discovered. The method should return quickly; e.g., it should not make remote calls.

Specified by:

discovered in interface DiscoveryListener

Parameters:

event - the event that describes the discovered registrars

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

AppendInitialLookupAttributes

protected void AppendInitialLookupAttributes(List<Entry> lookupAttributes)
                                      throws ServiceRegistrationException

Overrides:

AppendInitialLookupAttributes in class AbstractGigaSpacesService

Throws:

ServiceRegistrationException

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

waitForDrain

public void waitForDrain(long timeoutMs,
 long minTimeToWait,
 boolean isBackupOnly,
 org.slf4j.Logger logger)
                  throws TimeoutException

Throws:

TimeoutException

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)

updateClusterInfo

public void updateClusterInfo()

Description copied from interface: IRemoteJSpaceAdmin

trigger read of chunks map from zk and update clusterInfo

Specified by:

updateClusterInfo in interface IRemoteJSpaceAdmin

getPuName

public String getPuName()

getAttributeStore

public AttributeStore getAttributeStore()

waitForZkUpdate

public void waitForZkUpdate(Step step,
 String key,
 Status status)

clearBroadcastTables

public void clearBroadcastTables()

pullBroadcastTables

public boolean pullBroadcastTables()