public class SpaceImpl extends AbstractService implements IRemoteSpace, IInternalRemoteJSpaceAdmin, DiscoveryListener, TransactionParticipant, StatisticsAdmin
| Modifier and Type | Field and Description |
|---|---|
boolean |
_cleanUnusedEmbeddedGlobalXtns |
protected static String |
COMPONENT |
m_adminExporter, m_adminImplSERVICE_ATTRIBUTE_MODIFY_AWAITABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTINGREPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED| Constructor and Description |
|---|
SpaceImpl(String spaceName,
String containerName,
JSpaceContainerImpl container,
SpaceURL url,
JSpaceAttributes spaceConfig,
Properties customProperties,
boolean isSecondary,
boolean securityEnabled,
LifeCycle lifeCycle) |
| 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> |
executeOperation(RemoteOperationRequest<T> request) |
<T extends RemoteOperationResult> |
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) |
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 |
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) |
registerLookupServiceaddLookupAttributes, addLookupAttributes, getExporter, getJoinManager, getLifeCycle, getUuid, modifyLookupAttributes, registerLookupService, unregisterFromLookupServiceprotected static final String COMPONENT
public final boolean _cleanUnusedEmbeddedGlobalXtns
public SpaceImpl(String spaceName, String containerName, JSpaceContainerImpl container, SpaceURL url, JSpaceAttributes spaceConfig, Properties customProperties, boolean isSecondary, boolean securityEnabled, LifeCycle lifeCycle) throws CreateException, RemoteException
CreateExceptionRemoteExceptionpublic ZKCollocatedClientConfig getZkConfig()
public ZookeeperLastPrimaryHandler getZookeeperLastPrimaryHandler()
public String getContainerName()
getContainerName in class AbstractServicepublic String getInstanceId()
public String getNodeName()
public SpaceURL getURL()
public Properties getCustomProperties()
public JSpaceAttributes getJspaceAttr()
public JSpaceContainerImpl getContainer()
public org.slf4j.Logger getOperationLogger()
public boolean isPrivate()
public String getServiceName()
getServiceName in interface ILRMIServicegetServiceName in class AbstractGigaSpacesServiceprotected String getServiceTypeDescription()
getServiceTypeDescription in class AbstractGigaSpacesServicepublic Object getAdmin()
AbstractServicegetAdmin in interface AdministrablegetAdmin in class AbstractServiceJoinAdminpublic static String extractInstanceIdFromContainerName(String containerName)
public boolean isSecuredSpace()
public SpaceEngine getEngine()
public QuiesceHandler getQuiesceHandler()
public DirectPersistencyRecoveryHelper getDirectPersistencyRecoveryHelper()
public void beforeOperation(boolean isCheckForStandBy,
boolean checkQuiesceMode,
SpaceContext sc)
throws RemoteException
RemoteExceptionpublic void beforeTypeOperation(boolean isCheckForStandBy,
SpaceContext sc,
Privilege privilege,
String className)
throws RemoteException
RemoteExceptionpublic void beginPacketOperation(boolean isCheckForStandBy,
SpaceContext sc,
Privilege privilege,
ITransportPacket packet)
throws RemoteException
RemoteExceptionpublic void checkPacketAccessPrivileges(SpaceContext sc, Privilege privilege, ITransportPacket packet)
sc - Holds the security contextprivilege - The privilege required to perform this operation.packet - The packet applied to this operation (can be null).public void internalClean(boolean isInternalUse,
boolean isRestart,
boolean isWarmInit)
public void cleanOnDestroy()
public PrimarySpaceModeListeners getPrimarySpaceModeListeners()
public int getPartitionIdOneBased()
public int getPartitionId()
public void registerToClusterInfoChangedEvent(IClusterInfoChangedListener listener)
public void removeClusterInfoChangedListener(IClusterInfoChangedListener listener)
public IJSpace getSpaceProxy() throws RemoteException
RemoteExceptionpublic IDirectSpaceProxy getSingleProxy() throws RemoteException
RemoteExceptionprotected IJSpace getTaskProxy() throws RemoteException
RemoteExceptionprotected SpaceProxyImpl createProxy(boolean isClustered, boolean useEmbeddedCredentials) throws RemoteException
RemoteExceptionpublic SpaceSettings createSpaceSettingsWithNewClusterTopology(ClusterTopology newTopology)
public boolean isClusteredSpace()
public IRemoteSpace getSpaceStub() throws RemoteException
RemoteExceptionpublic static void setConfig(String spaceName, String containerName, JSpaceAttributes config, String spaceFileURL) throws RemoteException
RemoteExceptionpublic SpaceConfigReader getConfigReader()
public Uuid getSpaceUuid()
IRemoteSpacegetSpaceUuid in interface IRemoteSpacepublic void shutdown()
throws RemoteException
shutdown in class AbstractServiceRemoteExceptionServiceAdminImpl.destroy()public void shutdown(boolean isDestroy,
boolean shutdowContainer)
throws RemoteException
isDestroy - specify that space should be destroyed.shutdowContainer - If has true value and space container contains one
space, it will be also shutdown.RemoteExceptionpublic void unregister()
throws RemoteException
RemoteExceptionpublic void initAndRecoverFromDataStorage(boolean isWarm)
throws RemoteException,
CreateException,
SpaceComponentsInitializeException
isWarm - if set to true - the space will recover from databaseRemoteExceptionCreateExceptionSpaceComponentsInitializeExceptionpublic boolean useZooKeeper()
public boolean restartLeaderSelectorHandler()
public LeaderSelectorHandler getLeaderSelector()
public ClusterFailureDetector getClusterFailureDetector()
public void updateXmlConfigEntry(String configEntry, String configValue) throws IOException
IOExceptionpublic ServerTransaction createServerTransaction(TransactionManager mgr, Object id, int numOfParticipants)
public void changeSpaceState(int state,
boolean electable,
boolean replicable)
public LinkedList<ISpaceComponentsHandler> getSpaceComponentHandlers()
public SpaceHealthStatus getLocalSpaceHealthStatus()
public SecurityContext login(SecurityContext securityContext) throws RemoteException
RemoteSecuredServiceSecurityContextlogin in interface RemoteSecuredServicesecurityContext - security context to be used for authentication.RemoteException - communication-related exceptions that may occur during the execution
of a remote method call.public void addInternalSpaceModeListener(ISpaceModeListener listener)
public void removeInternalSpaceModeListener(ISpaceModeListener listener)
public SpaceProxyImpl getServiceProxy() throws RemoteException
ServiceProxyAccessornull.getServiceProxy in interface ServiceProxyAccessorRemoteExceptionpublic SpaceConnectResult connect(SpaceConnectRequest request) throws RemoteException
connect in interface IRemoteSpaceRemoteExceptionpublic boolean isAborted()
public DirectPersistencySyncListBatch getSynchronizationListBatch() throws RemoteException
getSynchronizationListBatch in interface IRemoteSpaceRemoteExceptionpublic void quiesce(String description, QuiesceToken token) throws RemoteException
quiesce in interface IRemoteSpaceRemoteExceptionpublic void unquiesce()
throws RemoteException
unquiesce in interface IRemoteSpaceRemoteExceptionpublic String getName()
IRemoteJSpaceAdmin
Usage:
spaceAdmin.getName()
getName in interface IRemoteSpacegetName in interface IRemoteJSpaceAdminpublic boolean isEmbedded()
isEmbedded in interface IRemoteSpacepublic void ping()
throws RemoteException
IRemoteJSpaceAdminUsage:
try
{
spaceAdmin.ping();
}
catch (RemoteException re)
{
System.err.println("Space not accessible");
}ping in interface IRemoteSpaceping in interface IRemoteJSpaceAdminRemoteException - if a communication error occursIRemoteJSpaceAdmin.getState()public SpaceHealthStatus getSpaceHealthStatus() throws RemoteException
getSpaceHealthStatus in interface IRemoteSpaceRemoteExceptionpublic IQueryProcessor getQueryProcessor()
getQueryProcessor in interface IRemoteSpacepublic IStubHandler getStubHandler()
public String getUniqueID() throws RemoteException
getUniqueID in interface IRemoteSpaceRemoteExceptionpublic Class<?> loadRemoteClass(String className) throws ClassNotFoundException
loadRemoteClass in interface IRemoteSpaceClassNotFoundExceptionpublic SpaceResponseInfo executeAction(SystemTask systemTask)
public boolean isActive()
throws RemoteException
isActive in interface RemoteOperationsExecutorRemoteExceptionpublic boolean isActiveAndNotSuspended()
throws RemoteException
isActiveAndNotSuspended in interface RemoteOperationsExecutorRemoteExceptionpublic Boolean isActiveAsync() throws RemoteException
isActiveAsync in interface RemoteOperationsExecutorRemoteExceptionpublic ClusterTopology checkChunkMapGeneration(int clientGeneration)
checkChunkMapGeneration in interface RemoteOperationsExecutorpublic <T extends RemoteOperationResult> T executeOperation(RemoteOperationRequest<T> request) throws RemoteException
executeOperation in interface RemoteOperationsExecutorRemoteExceptionpublic <T extends RemoteOperationResult> T executeOperationAsync(RemoteOperationRequest<T> request) throws RemoteException
executeOperationAsync in interface RemoteOperationsExecutorRemoteExceptionpublic void executeOperationOneway(RemoteOperationRequest<?> request) throws RemoteException
executeOperationOneway in interface RemoteOperationsExecutorRemoteExceptionpublic WriteEntryResult write(IEntryPacket entry, Transaction txn, long lease, int modifiers, boolean fromReplication, SpaceContext sc) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException
public LeaseContext<?>[] writeOld(IEntryPacket[] entries, Transaction txn, long lease, long[] leases, SpaceContext sc, int modifiers) throws TransactionException, UnknownTypesException, RemoteException
public WriteEntriesResult write(IEntryPacket[] entries, Transaction txn, long lease, long[] leases, SpaceContext sc, long timeout, int modifiers, boolean newRouter) throws TransactionException, UnknownTypesException, RemoteException
public AnswerPacket update(IEntryPacket entry, Transaction txn, long lease, long timeout, SpaceContext sc, int modifiers, boolean newRouter) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException, InterruptedException
public Pair<Integer,SingleExplainPlan> count(ITemplatePacket template, Transaction txn, SpaceContext sc, int modifiers) throws UnusableEntryException, UnknownTypeException, TransactionException, RemoteException
public Pair<Integer,SingleExplainPlan> clear(ITemplatePacket template, Transaction txn, int modifiers, SpaceContext sc) throws UnusableEntryException, UnknownTypeException, TransactionException, RemoteException
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
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
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
public ServerIteratorAnswerHolder getNextBatchFromServerIterator(ITemplatePacket template, SpaceContext sc, int modifiers, ServerIteratorRequestInfo serverIteratorRequestInfo) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException, InterruptedException
public void closeServerIterator(UUID uuid)
public void renewServerIteratorLease(UUID uuid)
public IEntryPacket[] readMultiple(ITemplatePacket template, Transaction txn, boolean take, int maxEntries, SpaceContext sc, boolean returnOnlyUid, int modifiers) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException
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
public static void applyEntryPacketOutFilter(IEntryPacket entryPacket, int modifiers, AbstractProjectionTemplate projectionTemplate)
public IEntryPacket[] readByIds(ITemplatePacket template, Transaction txn, boolean take, SpaceContext spaceContext, int modifiers) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException, InterruptedException
public Map<Object,EntryTieredMetaData> getEntriesTieredMetaDataByIds(String typeName, Object[] ids) throws Exception
Exceptionpublic GSEventRegistration notify(ITemplatePacket template, Transaction txn, long lease, SpaceContext sc, NotifyInfo info) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException
public void snapshot(ITemplatePacket template) throws UnusableEntryException, RemoteException
snapshot in interface IRemoteSpaceUnusableEntryExceptionRemoteExceptionpublic void cancel(String entryUID, String classname, int objectType, boolean isFromGateway) throws UnknownLeaseException, RemoteException
UnknownLeaseExceptionRemoteExceptionpublic void cancel(String entryUID, String classname, int objectType) throws UnknownLeaseException, RemoteException
cancel in interface IRemoteSpaceUnknownLeaseExceptionRemoteExceptionpublic long renew(String entryUID, String classname, int objectType, long duration, boolean isFromGateway) throws UnknownLeaseException, RemoteException
UnknownLeaseExceptionRemoteExceptionpublic long renew(String entryUID, String classname, int objectType, long duration) throws LeaseDeniedException, UnknownLeaseException, RemoteException
renew in interface IRemoteSpaceLeaseDeniedExceptionUnknownLeaseExceptionRemoteExceptionpublic Exception[] cancelAll(String[] entryUIDs, String[] classnames, int[] objectTypes) throws RemoteException
cancelAll in interface IRemoteSpaceRemoteExceptionpublic Object[] renewAll(String[] entryUIDs, String[] classnames, int[] objectTypes, long[] durations) throws RemoteException
renewAll in interface IRemoteSpaceRemoteExceptionpublic void abort(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipantabort in interface TransactionParticipantmgr - the manager of the transactionid - the transaction IDUnknownTransactionException - 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 errorpublic void abort(TransactionManager mgr, Object id) throws UnknownTransactionException, RemoteException
abort in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic void abortImpl(TransactionManager mgr, Object id, boolean supportsTwoPhaseReplication, OperationID operationID) throws RemoteException, UnknownTransactionException
public void commit(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED 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.commit in interface TransactionParticipantmgr - the manager of the transactionid - the transaction IDUnknownTransactionException - 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 errorpublic void commit(TransactionManager mgr, Object id) throws UnknownTransactionException, RemoteException
commit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic void commit(TransactionManager mgr, long id, int numOfParticipants) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED 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.commit in interface TransactionParticipantmgr - the manager of the transactionid - the transaction IDnumOfParticipants - the total number of transaction participants this is needed only in
commit , since prepareAndCommit is called for single participantUnknownTransactionException - 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 errorpublic void commit(TransactionManager mgr, Object id, int numOfParticipants) throws UnknownTransactionException, RemoteException
commit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic void commitImpl(TransactionManager mgr, Object id, int numOfParticipants, boolean supportsTwoPhaseReplication, OperationID operationID, boolean mayBeFromReplication) throws RemoteException, UnknownTransactionException
public int prepare(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED,
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.prepare in interface TransactionParticipantmgr - the manager of the transactionid - the transaction IDint representing this participant's stateUnknownTransactionException - 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 errorpublic int prepare(TransactionManager mgr, Object id) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepare(TransactionManager mgr, Object id, int numOfParticipants) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager mgr, long id, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager mgr, Object parm2, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager mgr, Object parm2, int numOfParticipants, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepareAndCommit(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipantprepare 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;
}
prepareAndCommit in interface TransactionParticipantmgr - the manager of the transactionid - the transaction IDint representing its stateUnknownTransactionException - 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 errorTransactionParticipant.prepare(net.jini.core.transaction.server.TransactionManager, long),
TransactionParticipant.commit(net.jini.core.transaction.server.TransactionManager, long)public int prepareAndCommit(TransactionManager mgr, Object id) throws UnknownTransactionException, RemoteException
prepareAndCommit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepareAndCommitImpl(TransactionManager mgr, Object id, OperationID operationID) throws RemoteException, UnknownTransactionException
public void renewLease(TransactionManager mgr, long id, long time) throws LeaseDeniedException, UnknownLeaseException, RemoteException
TransactionParticipantrenewLease in interface TransactionParticipantLeaseDeniedExceptionUnknownLeaseExceptionRemoteExceptionpublic Object executeTask(SpaceTask task, Transaction tx, SpaceContext sc, boolean newRouter) throws RemoteException, ExecutionException
RemoteExceptionExecutionExceptionpublic IReplicationConnectionProxy getReplicationRouterConnectionProxy() throws RemoteException
getReplicationRouterConnectionProxy in interface IRemoteSpaceRemoteExceptionpublic NIODetails getNIODetails()
NIOInfoProvidergetNIODetails in interface NIOInfoProviderpublic NIOStatistics getNIOStatistics()
NIOInfoProvidergetNIOStatistics in interface NIOInfoProviderpublic void enableLRMIMonitoring()
throws RemoteException
NIOInfoProviderNIOInfoProvider.fetchLRMIMonitoringDetails()enableLRMIMonitoring in interface NIOInfoProviderRemoteExceptionpublic void disableLRMIMonitoring()
throws RemoteException
NIOInfoProviderNIOInfoProvider.enableLRMIMonitoring()disableLRMIMonitoring in interface NIOInfoProviderRemoteExceptionpublic LRMIMonitoringDetails fetchLRMIMonitoringDetails() throws RemoteException
NIOInfoProviderNIOInfoProvider.enableLRMIMonitoring()fetchLRMIMonitoringDetails in interface NIOInfoProviderRemoteExceptionpublic long getCurrentTimestamp()
getCurrentTimestamp in interface OSInfoProviderpublic OSDetails getOSDetails()
getOSDetails in interface OSInfoProviderpublic OSStatistics getOSStatistics()
getOSStatistics in interface OSInfoProviderpublic JVMDetails getJVMDetails()
getJVMDetails in interface JVMInfoProviderpublic JVMStatistics getJVMStatistics()
getJVMStatistics in interface JVMInfoProviderpublic void runGc()
runGc in interface JVMInfoProviderpublic String[] getZones()
getZones in interface GridZoneProviderpublic boolean isStatisticsAvailable()
StatisticsAdminisStatisticsAvailable in interface StatisticsAdmintrue if space statistics is availablepublic String[] getStatisticsStringArray() throws StatisticsNotAvailable
StatisticsAdmingetStatisticsStringArray in interface StatisticsAdminStatisticsNotAvailable - when space statistics are not availablepublic long getStatisticsSamplingRate()
throws StatisticsNotAvailable
StatisticsAdmingetStatisticsSamplingRate in interface StatisticsAdminStatisticsNotAvailable - when space statistics are not availablepublic void setStatisticsSamplingRate(long rate)
throws StatisticsNotAvailable
StatisticsAdminsetStatisticsSamplingRate in interface StatisticsAdminrate - the rate to sample the space for statisticsStatisticsNotAvailable - when space statistics are not availablepublic Map<Integer,StatisticsContext> getStatistics() throws StatisticsNotAvailable
StatisticsAdminStatisticsContext objects for all filter
operation codes.getStatistics in interface StatisticsAdminStatisticsContextStatisticsNotAvailable - when space statistics are not availablepublic StatisticsContext getStatistics(int operationCode) throws StatisticsNotAvailable
StatisticsAdminStatisticsContext for specific
filter operation code.getStatistics in interface StatisticsAdminoperationCode - filter operation code defined in FilterOperationCodesStatisticsNotAvailable - when space statistics are not availableFilterOperationCodespublic Map<Integer,StatisticsContext> getStatistics(Integer[] operationCodes) throws StatisticsNotAvailable
StatisticsAdminStatisticsContext objects for passed specific
filter operation codes.getStatistics in interface StatisticsAdminoperationCodes - filter array of operation codes defined in FilterOperationCodesStatisticsContextStatisticsNotAvailable - when space statistics are not availablepublic StatisticsHolder getHolder()
getHolder in interface StatisticsAdminpublic Map<String,Object> getMetricSnapshots(Collection<String> prefixes) throws RemoteException
getMetricSnapshots in interface StatisticsAdminprefixes - collection of metrics prefixesRemoteExceptionpublic SpaceRuntimeInfo getRuntimeInfo() throws RemoteException
IRemoteJSpaceAdminSpaceRuntimeInfo.
Usage:
SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo();
List classNames = runtime.m_ClassNames;
List numOfEntries = runtime.m_NumOFEntries;
getRuntimeInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic SpaceRuntimeInfo getRuntimeInfo(String className) throws RemoteException
IRemoteJSpaceAdminSpaceRuntimeInfo 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;
getRuntimeInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic SpaceConfig getConfig()
IRemoteJSpaceAdminSpaceConfig of this space.
Usage:
SpaceConfig config = spaceAdmin.getConfig();
if (config != null)
boolean isClustered = config.m_isClustered;
getConfig in interface IRemoteJSpaceAdminpublic void start()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.start();
start in interface IInternalRemoteJSpaceAdminRemoteException - - Failed to start space.SpaceAlreadyStartedException - - The space is already startedpublic void startInternal()
throws RemoteException
RemoteExceptionpublic void stop()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.stop();
stop in interface IInternalRemoteJSpaceAdminRemoteException - - Failed to stop space.SpaceAlreadyStoppedException - - The space is already stoppedpublic void stopInternal()
throws RemoteException
RemoteExceptionpublic void restart()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
try
{
spaceAdmin.restart();
}
catch( java.rmi.RemoteException ex )
{
System.err.println("Failed to restart space: " + ((IJSpace)space).getName());
System.err.println("Exception: " + ex);
}
restart in interface IInternalRemoteJSpaceAdminRemoteException - Failed to restart space.public SpaceInstanceRemoteClassLoaderInfo getSpaceInstanceRemoteClassLoaderInfo()
IRemoteJSpaceAdmingetSpaceInstanceRemoteClassLoaderInfo in interface IRemoteJSpaceAdminpublic Object[] getReplicationStatus() throws RemoteException
getReplicationStatus in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic ClusterPolicy getClusterPolicy()
IRemoteJSpaceAdmingetClusterPolicy in interface IRemoteJSpaceAdminpublic SpaceClusterInfo getClusterInfo()
public BasicTypeInfo getClassTypeInfo(String className) throws RemoteException
IRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassTypeInfo in interface IRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic void dropClass(String className, SpaceContext sc) throws RemoteException, DropClassException
dropClass in interface IRemoteJSpaceAdminclassName - - name of class to delete.RemoteException - if a communication error occursDropClassException - Failed to drop desired class.public void directDropCLassForAllProxies(String className)
public int getState()
IRemoteJSpaceAdmingetState in interface IRemoteJSpaceAdminISpaceStatepublic void disableStub()
throws RemoteException
IInternalRemoteJSpaceAdmindisableStub in interface IInternalRemoteJSpaceAdminRemoteException - if a communication error occurspublic RuntimeHolder getRuntimeHolder() throws RemoteException
getRuntimeHolder in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic boolean isStartedWithinGSC()
isStartedWithinGSC in interface IInternalRemoteJSpaceAdminpublic String getDeployPath()
public SpaceCopyStatus spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize)
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - EntryPacket template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.public SpaceCopyStatus spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext sc) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - EntryPacket template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.sc - SpaceContext for security check in the server side.RemoteException - if a communication error occurspublic SpaceCopyStatus spaceCopy(IRemoteSpace remoteProxy, String remoteSpaceUrl, String remoteSpaceName, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext sc, SpaceContext remoteSpaceContext) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( remoteProxy, remoteURL, remoteName,
template, false 1000, sc);
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteProxy - ISpaceInternal, a proxy to the remote space to copy fromremoteSpaceUrl - 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 toochunkSize - 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.RemoteException - if a communication error occurspublic TransactionInfo[] getTransactionsInfo(int type, int status) throws RemoteException
IInternalRemoteJSpaceAdmingetTransactionsInfo in interface IInternalRemoteJSpaceAdmintype - 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 TransactionConstantsRemoteException - if a communication error occurspublic int countTransactions(int type,
int status)
throws RemoteException
countTransactions in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic List<TemplateInfo> getTemplatesInfo(String className) throws RemoteException
IInternalRemoteJSpaceAdmingetTemplatesInfo in interface IInternalRemoteJSpaceAdminclassName - name of the class to searchRemoteExceptionpublic List<ITransportConnection> getConnectionsInfo() throws RemoteException
getConnectionsInfo in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic int countIncomingConnections()
throws RemoteException
countIncomingConnections in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic List<UnderTxnLockedObject> getLockedObjects(Transaction txn) throws RemoteException
getLockedObjects in interface IInternalRemoteJSpaceAdmintxn - - the Transaction that locks the Objects.RemoteExceptionpublic SpaceMode getSpaceMode()
IInternalRemoteJSpaceAdminSpaceMode 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.
getSpaceMode in interface IInternalRemoteJSpaceAdminSpaceMode of the space.public boolean isPrimary()
public boolean isBackup()
public SpaceMode addSpaceModeListener(ISpaceModeListener listener)
IInternalRemoteJSpaceAdminISpaceModeListener 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.
addSpaceModeListener in interface IInternalRemoteJSpaceAdminlistener - a listener to be called back on space mode changes.SpaceMode of the space.ISpaceModeListener,
SpaceModepublic void removeSpaceModeListener(ISpaceModeListener listener)
IInternalRemoteJSpaceAdminremoveSpaceModeListener in interface IInternalRemoteJSpaceAdminlistener - a listener to be removed.IInternalRemoteJSpaceAdmin.addSpaceModeListener(ISpaceModeListener)public ITypeDesc getClassDescriptor(String className) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassDescriptor in interface IInternalRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic ITypeDesc getClassDescriptor(String className, boolean asVirtualType) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassDescriptor in interface IInternalRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic void forceMoveToPrimary()
throws RemoteException
IInternalRemoteJSpaceAdminforceMoveToPrimary in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic String getReplicationDump()
getReplicationDump in interface IInternalRemoteJSpaceAdminpublic int flushRedoLogToStorage()
throws RemoteException
IInternalRemoteJSpaceAdminflushRedoLogToStorage in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic void assertAuthorizedForType(String typeName, SpaceAuthority.SpacePrivilege privilege, SpaceContext spaceContext)
public void assertAuthorizedForPrivilege(Privilege privilege, SpaceContext spaceContext)
public boolean isRecovering()
public AtomicBoolean getRecoveryIndicator()
public Map<String,LocalCacheDetails> getLocalCacheDetails() throws RemoteException
getLocalCacheDetails in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic Map<String,LocalViewDetails> getLocalViewDetails() throws RemoteException
getLocalViewDetails in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic boolean isLocalCache()
public SpaceCopyStatus spaceCopy(String remoteUrl, Object template, boolean includeNotifyTemplates, int chunkSize)
spaceCopy in interface IRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - Entry template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.public SpaceCopyStatus spaceCopy(IJSpace remoteSpace, Object template, boolean includeNotifyTemplates, int chunkSize)
spaceCopy in interface IRemoteJSpaceAdminpublic void discarded(DiscoveryEvent event)
DiscoveryListenerdiscarded in interface DiscoveryListenerevent - the event that describes the discarded registrarspublic void discovered(DiscoveryEvent event)
DiscoveryListenerdiscovered in interface DiscoveryListenerevent - the event that describes the discovered registrarspublic byte[] getClusterConfigFile()
throws RemoteException
IInternalRemoteJSpaceAdmingetClusterConfigFile in interface IInternalRemoteJSpaceAdminRemoteException - if a communication error occurspublic void setClusterConfigFile(byte[] config)
throws RemoteException
IInternalRemoteJSpaceAdminsetClusterConfigFile in interface IInternalRemoteJSpaceAdminconfig - byte representation of the configuration fileRemoteException - if a communication error occursprotected void AppendInitialLookupAttributes(List<Entry> lookupAttributes) throws ServiceRegistrationException
AppendInitialLookupAttributes in class AbstractGigaSpacesServiceServiceRegistrationExceptionpublic void demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc)
throws DemoteFailedException,
RemoteException
IRemoteSpacedemote in interface IRemoteSpacemaxSuspendTime - 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.DemoteFailedExceptionRemoteExceptionpublic void waitForDrain(long timeoutMs,
long minTimeToWait,
boolean isBackupOnly,
org.slf4j.Logger logger)
throws TimeoutException
TimeoutExceptionpublic SuspendType addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdminSuspendTypeChangedInternalListener suspend type changes.addSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdminlistener - - SuspendTypeChangedInternalListener that will receive notification when a space suspend type changes (SuspendType)public void removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdminremoveSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdminlistener - - SuspendTypeChangedInternalListener that will stop receiving notification when a space suspend type changes (SuspendType)public void updateClusterInfo()
IRemoteJSpaceAdminupdateClusterInfo in interface IRemoteJSpaceAdminpublic String getPuName()
public AttributeStore getAttributeStore()
public void clearBroadcastTables()
public boolean pullBroadcastTables()
Copyright © GigaSpaces.