SpaceImpl (GigaSpaces 16.3.0 API)

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 and Description

boolean _cleanUnusedEmbeddedGlobalXtns

protected static 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 net.jini.core.transaction.server.TransactionConstants
  ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING
- Fields inherited from interface com.j_spaces.core.admin.IRemoteJSpaceAdmin
  REPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED

Fields
Modifier and Type	Field and Description
`boolean`	`_cleanUnusedEmbeddedGlobalXtns`
`protected static String`	`COMPONENT`

Constructor Summary

Constructors
Constructor and Description
`SpaceImpl(String spaceName, String containerName, JSpaceContainerImpl container, SpaceURL url, JSpaceAttributes spaceConfig, Properties customProperties, boolean isSecondary, boolean securityEnabled, LifeCycle lifeCycle)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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`	`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.
`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)`
`<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.
`int`	`flushRedoLogToStorage()` Flush redo-log packets from memory to underlying storage.
`void`	`forceMoveToPrimary()` Forcefully make this space to be primary
`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)`
`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()`
`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`	`isMVCCEntryDirtyUnderTransaction(String typeName, Object id, long transactionId)`
`boolean`	`isPrimary()`
`boolean`	`isPrivate()`
`boolean`	`isRecovering()`
`boolean`	`isSecuredSpace()`
`boolean`	`isStartedWithinGSC()`
`boolean`	`isStatisticsAvailable()` Checks if space statistics is available.
`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)`
`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`	`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)`
`SpaceCopyStatus`	`spaceCopy(IJSpace remoteSpace, Object template, boolean includeNotifyTemplates, int chunkSize)`
`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(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()`
`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)`

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 Detail

COMPONENT

protected static final String COMPONENT

See Also:: Constant Field Values

_cleanUnusedEmbeddedGlobalXtns

public final boolean _cleanUnusedEmbeddedGlobalXtns

Constructor Detail

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 Detail

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

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

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

Specified by:

getName in interface IRemoteJSpaceAdmin

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 IRemoteSpace

Specified by:

ping in interface IRemoteJSpaceAdmin

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)

isMVCCEntryDirtyUnderTransaction

public boolean isMVCCEntryDirtyUnderTransaction(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)
              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

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

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

Class SpaceImpl

Field Summary

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

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

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

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

Constructor Summary

Method Summary

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

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

Methods inherited from class java.lang.Object

Field Detail

COMPONENT

_cleanUnusedEmbeddedGlobalXtns

Constructor Detail

SpaceImpl

Method Detail

getZkConfig

getZookeeperLastPrimaryHandler

getContainerName

getInstanceId

getNodeName

getURL

getCustomProperties

getJspaceAttr

getContainer

getOperationLogger

isPrivate

getServiceName

getServiceTypeDescription

getAdmin

extractInstanceIdFromContainerName

extractContainerName

extractInstanceId

isSecuredSpace

getEngine

getQuiesceHandler

getDirectPersistencyRecoveryHelper

beforeOperation

beforeTypeOperation

beginPacketOperation

checkPacketAccessPrivileges

internalClean

cleanOnDestroy

getPrimarySpaceModeListeners

getPartitionIdOneBased

getPartitionId

registerToClusterInfoChangedEvent

isMvccEnabled

removeClusterInfoChangedListener

getSpaceProxy

getSingleProxy

getTaskProxy

createProxy

createSpaceSettingsWithNewClusterTopology

isClusteredSpace

getSpaceStub

toString

setConfig

getConfigReader

getSpaceUuid

shutdown

shutdown

unregister

initAndRecoverFromDataStorage

useZooKeeper

restartLeaderSelectorHandler

getLeaderSelector

getClusterFailureDetector

updateXmlConfigEntry

createServerTransaction

changeSpaceState

getSpaceComponentHandlers

getLocalSpaceHealthStatus

login

addInternalSpaceModeListener

removeInternalSpaceModeListener

getServiceProxy

connect

isAborted