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_adminImpl
SERVICE_ATTRIBUTE_MODIFY_AWAIT
ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING
REPLICATION_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) |
MVCCEntryMetaData |
getMVCCDirtyEntryMetaDataUnderTransaction(String typeName,
Object id,
long transactionId) |
ArrayList<MVCCEntryMetaData> |
getMVCCEntryMetaData(String typeName,
Object id) |
String |
getName()
Returns the Space Name.
|
ServerIteratorAnswerHolder |
getNextBatchFromServerIterator(ITemplatePacket template,
SpaceContext sc,
int modifiers,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
NIODetails |
getNIODetails()
Returns the transport configuration.
|
NIOStatistics |
getNIOStatistics()
Returns the transport statistics.
|
String |
getNodeName() |
org.slf4j.Logger |
getOperationLogger() |
OSDetails |
getOSDetails() |
OSStatistics |
getOSStatistics() |
int |
getPartitionId() |
int |
getPartitionIdOneBased() |
PrimarySpaceModeListeners |
getPrimarySpaceModeListeners() |
String |
getPuName() |
IQueryProcessor |
getQueryProcessor() |
QuiesceHandler |
getQuiesceHandler() |
AtomicBoolean |
getRecoveryIndicator() |
String |
getReplicationDump() |
IReplicationConnectionProxy |
getReplicationRouterConnectionProxy() |
Object[] |
getReplicationStatus()
return the replication status of all my replication group returns an array of remote member
names and an array of replication status to them.
|
RuntimeHolder |
getRuntimeHolder() |
SpaceRuntimeInfo |
getRuntimeInfo()
Returns
SpaceRuntimeInfo . |
SpaceRuntimeInfo |
getRuntimeInfo(String className)
Returns
SpaceRuntimeInfo for specific class name and its subclasses. |
String |
getServiceName() |
SpaceProxyImpl |
getServiceProxy()
Returns a proxy object for this object.
|
protected String |
getServiceTypeDescription() |
IDirectSpaceProxy |
getSingleProxy()
Return the internal instance of embedded not-clustered space proxy.
|
LinkedList<ISpaceComponentsHandler> |
getSpaceComponentHandlers()
Create a list of all space component handlers
|
SpaceHealthStatus |
getSpaceHealthStatus() |
SpaceInstanceRemoteClassLoaderInfo |
getSpaceInstanceRemoteClassLoaderInfo()
Return the info about the space classloader
|
SpaceMode |
getSpaceMode()
Get the current
SpaceMode which represents the current state of this participant in
the election process. |
IJSpace |
getSpaceProxy()
Return the internal instance of space proxy.
|
IRemoteSpace |
getSpaceStub() |
Uuid |
getSpaceUuid()
returns the universal unique identifier of the remote space
|
int |
getState()
Returns the particular condition of this space.
|
Map<Integer,StatisticsContext> |
getStatistics()
Returns statistics repository that contains a map of operation codes to
StatisticsContext objects for all filter
operation codes. |
StatisticsContext |
getStatistics(int operationCode)
Returns a
StatisticsContext for specific
filter operation code. |
Map<Integer,StatisticsContext> |
getStatistics(Integer[] operationCodes)
Returns statistics repository that contains a map of operation codes to
StatisticsContext objects for passed specific
filter operation codes. |
long |
getStatisticsSamplingRate()
Checks statistics sampling rate.
|
String[] |
getStatisticsStringArray()
Returns a string array contains statistics values for each operation.
|
IStubHandler |
getStubHandler() |
DirectPersistencySyncListBatch |
getSynchronizationListBatch() |
protected IJSpace |
getTaskProxy() |
List<TemplateInfo> |
getTemplatesInfo(String className)
Returns a list of pending templates.
|
TransactionInfo[] |
getTransactionsInfo(int type,
int status)
Returns all the transactions with the specific parameters.
|
String |
getUniqueID()
Generates and returns a unique id
|
SpaceURL |
getURL()
Returns the SpaceURL object which initialized that specific space instance.
|
ZKCollocatedClientConfig |
getZkConfig() |
String[] |
getZones() |
ZookeeperLastPrimaryHandler |
getZookeeperLastPrimaryHandler() |
void |
initAndRecoverFromDataStorage(boolean isWarm)
Initialize main space components
|
void |
internalClean(boolean isInternalUse,
boolean isRestart,
boolean isWarmInit) |
boolean |
isAborted() |
boolean |
isActive() |
boolean |
isActiveAndNotSuspended() |
Boolean |
isActiveAsync() |
boolean |
isBackup() |
boolean |
isClusteredSpace() |
boolean |
isEmbedded() |
boolean |
isLocalCache() |
boolean |
isMvccEnabled() |
boolean |
isPrimary() |
boolean |
isPrivate() |
boolean |
isRecovering() |
boolean |
isSecuredSpace() |
boolean |
isStartedWithinGSC() |
boolean |
isStatisticsAvailable()
Checks if space statistics is available.
|
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) |
void |
snapshot(ITemplatePacket template,
SpaceContext sc) |
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) |
registerLookupService
addLookupAttributes, addLookupAttributes, getExporter, getJoinManager, getLifeCycle, getUuid, modifyLookupAttributes, registerLookupService, unregisterFromLookupService
protected 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
CreateException
RemoteException
public ZKCollocatedClientConfig getZkConfig()
public ZookeeperLastPrimaryHandler getZookeeperLastPrimaryHandler()
public String getContainerName()
getContainerName
in class AbstractService
public 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 ILRMIService
getServiceName
in class AbstractGigaSpacesService
protected String getServiceTypeDescription()
getServiceTypeDescription
in class AbstractGigaSpacesService
public Object getAdmin()
AbstractService
getAdmin
in interface Administrable
getAdmin
in class AbstractService
JoinAdmin
public 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
RemoteException
public void beforeTypeOperation(boolean isCheckForStandBy, SpaceContext sc, Privilege privilege, String className) throws RemoteException
RemoteException
public void beginPacketOperation(boolean isCheckForStandBy, SpaceContext sc, Privilege privilege, ITransportPacket packet) throws RemoteException
RemoteException
public 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 boolean isMvccEnabled()
public void removeClusterInfoChangedListener(IClusterInfoChangedListener listener)
public IJSpace getSpaceProxy() throws RemoteException
RemoteException
public IDirectSpaceProxy getSingleProxy() throws RemoteException
RemoteException
protected IJSpace getTaskProxy() throws RemoteException
RemoteException
protected SpaceProxyImpl createProxy(boolean isClustered, boolean useEmbeddedCredentials) throws RemoteException
RemoteException
public SpaceSettings createSpaceSettingsWithNewClusterTopology(ClusterTopology newTopology)
public boolean isClusteredSpace()
public IRemoteSpace getSpaceStub() throws RemoteException
RemoteException
public static void setConfig(String spaceName, String containerName, JSpaceAttributes config, String spaceFileURL) throws RemoteException
RemoteException
public SpaceConfigReader getConfigReader()
public Uuid getSpaceUuid()
IRemoteSpace
getSpaceUuid
in interface IRemoteSpace
public void shutdown() throws RemoteException
shutdown
in class AbstractService
RemoteException
ServiceAdminImpl.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.RemoteException
public void unregister() throws RemoteException
RemoteException
public void initAndRecoverFromDataStorage(boolean isWarm) throws RemoteException, CreateException, SpaceComponentsInitializeException
isWarm
- if set to true - the space will recover from databaseRemoteException
CreateException
SpaceComponentsInitializeException
public boolean useZooKeeper()
public boolean restartLeaderSelectorHandler()
public LeaderSelectorHandler getLeaderSelector()
public ClusterFailureDetector getClusterFailureDetector()
public void updateXmlConfigEntry(String configEntry, String configValue) throws IOException
IOException
public 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
RemoteSecuredService
SecurityContext
login
in interface RemoteSecuredService
securityContext
- 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
ServiceProxyAccessor
null
.getServiceProxy
in interface ServiceProxyAccessor
RemoteException
public SpaceConnectResult connect(SpaceConnectRequest request) throws RemoteException
connect
in interface IRemoteSpace
RemoteException
public boolean isAborted()
public DirectPersistencySyncListBatch getSynchronizationListBatch() throws RemoteException
getSynchronizationListBatch
in interface IRemoteSpace
RemoteException
public void quiesce(String description, QuiesceToken token) throws RemoteException
quiesce
in interface IRemoteSpace
RemoteException
public void unquiesce() throws RemoteException
unquiesce
in interface IRemoteSpace
RemoteException
public String getName()
IRemoteJSpaceAdmin
Usage:
spaceAdmin.getName()
getName
in interface IRemoteSpace
getName
in interface IRemoteJSpaceAdmin
public boolean isEmbedded()
isEmbedded
in interface IRemoteSpace
public void ping() throws RemoteException
IRemoteJSpaceAdmin
Usage:
try
{
spaceAdmin.ping();
}
catch (RemoteException re)
{
System.err.println("Space not accessible");
}
ping
in interface IRemoteSpace
ping
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occursIRemoteJSpaceAdmin.getState()
public SpaceHealthStatus getSpaceHealthStatus() throws RemoteException
getSpaceHealthStatus
in interface IRemoteSpace
RemoteException
public IQueryProcessor getQueryProcessor()
getQueryProcessor
in interface IRemoteSpace
public IStubHandler getStubHandler()
public String getUniqueID() throws RemoteException
getUniqueID
in interface IRemoteSpace
RemoteException
public Class<?> loadRemoteClass(String className) throws ClassNotFoundException
loadRemoteClass
in interface IRemoteSpace
ClassNotFoundException
public SpaceResponseInfo executeAction(SystemTask systemTask)
public boolean isActive() throws RemoteException
isActive
in interface RemoteOperationsExecutor
RemoteException
public boolean isActiveAndNotSuspended() throws RemoteException
isActiveAndNotSuspended
in interface RemoteOperationsExecutor
RemoteException
public Boolean isActiveAsync() throws RemoteException
isActiveAsync
in interface RemoteOperationsExecutor
RemoteException
public ClusterTopology checkChunkMapGeneration(int clientGeneration)
checkChunkMapGeneration
in interface RemoteOperationsExecutor
public <T extends RemoteOperationResult> T executeOperation(RemoteOperationRequest<T> request) throws RemoteException
executeOperation
in interface RemoteOperationsExecutor
RemoteException
public <T extends RemoteOperationResult> T executeOperationAsync(RemoteOperationRequest<T> request) throws RemoteException
executeOperationAsync
in interface RemoteOperationsExecutor
RemoteException
public void executeOperationOneway(RemoteOperationRequest<?> request) throws RemoteException
executeOperationOneway
in interface RemoteOperationsExecutor
RemoteException
public 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
Exception
public ArrayList<MVCCEntryMetaData> getMVCCEntryMetaData(String typeName, Object id)
public MVCCEntryMetaData getMVCCDirtyEntryMetaDataUnderTransaction(String typeName, Object id, long transactionId)
public GSEventRegistration notify(ITemplatePacket template, Transaction txn, long lease, SpaceContext sc, NotifyInfo info) throws TransactionException, UnusableEntryException, UnknownTypeException, RemoteException
public void snapshot(ITemplatePacket template, SpaceContext sc) throws UnusableEntryException, RemoteException
snapshot
in interface IRemoteSpace
UnusableEntryException
RemoteException
public void snapshot(ITemplatePacket template) throws UnusableEntryException, RemoteException
snapshot
in interface IRemoteSpace
UnusableEntryException
RemoteException
public void cancel(String entryUID, String classname, int objectType, boolean isFromGateway) throws UnknownLeaseException, RemoteException
UnknownLeaseException
RemoteException
public void cancel(String entryUID, String classname, int objectType) throws UnknownLeaseException, RemoteException
cancel
in interface IRemoteSpace
UnknownLeaseException
RemoteException
public long renew(String entryUID, String classname, int objectType, long duration, boolean isFromGateway) throws UnknownLeaseException, RemoteException
UnknownLeaseException
RemoteException
public long renew(String entryUID, String classname, int objectType, long duration) throws LeaseDeniedException, UnknownLeaseException, RemoteException
renew
in interface IRemoteSpace
LeaseDeniedException
UnknownLeaseException
RemoteException
public Exception[] cancelAll(String[] entryUIDs, String[] classnames, int[] objectTypes) throws RemoteException
cancelAll
in interface IRemoteSpace
RemoteException
public Object[] renewAll(String[] entryUIDs, String[] classnames, int[] objectTypes, long[] durations) throws RemoteException
renewAll
in interface IRemoteSpace
RemoteException
public void abort(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipant
abort
in interface TransactionParticipant
mgr
- 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 IRemoteSpace
UnknownTransactionException
RemoteException
public void abortImpl(TransactionManager mgr, Object id, boolean supportsTwoPhaseReplication, OperationID operationID) throws RemoteException, UnknownTransactionException
public void commit(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipant
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.commit
in interface TransactionParticipant
mgr
- 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 IRemoteSpace
UnknownTransactionException
RemoteException
public void commit(TransactionManager mgr, long id, int numOfParticipants) throws UnknownTransactionException, RemoteException
TransactionParticipant
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.commit
in interface TransactionParticipant
mgr
- 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 IRemoteSpace
UnknownTransactionException
RemoteException
public 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
TransactionParticipant
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.prepare
in interface TransactionParticipant
mgr
- 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 IRemoteSpace
UnknownTransactionException
RemoteException
public int prepare(TransactionManager mgr, Object id, int numOfParticipants) throws UnknownTransactionException, RemoteException
prepare
in interface IRemoteSpace
UnknownTransactionException
RemoteException
public Object prepare(TransactionManager mgr, long id, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare
in interface IRemoteSpace
UnknownTransactionException
RemoteException
public Object prepare(TransactionManager mgr, Object parm2, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare
in interface IRemoteSpace
UnknownTransactionException
RemoteException
public Object prepare(TransactionManager mgr, Object parm2, int numOfParticipants, boolean needClusteredProxy) throws UnknownTransactionException, RemoteException
prepare
in interface IRemoteSpace
UnknownTransactionException
RemoteException
public int prepareAndCommit(TransactionManager mgr, long id) throws UnknownTransactionException, RemoteException
TransactionParticipant
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; }
prepareAndCommit
in interface TransactionParticipant
mgr
- 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 IRemoteSpace
UnknownTransactionException
RemoteException
public int prepareAndCommitImpl(TransactionManager mgr, Object id, OperationID operationID) throws RemoteException, UnknownTransactionException
public void renewLease(TransactionManager mgr, long id, long time) throws LeaseDeniedException, UnknownLeaseException, RemoteException
TransactionParticipant
renewLease
in interface TransactionParticipant
LeaseDeniedException
UnknownLeaseException
RemoteException
public Object executeTask(SpaceTask task, Transaction tx, SpaceContext sc, boolean newRouter) throws RemoteException, ExecutionException
RemoteException
ExecutionException
public IReplicationConnectionProxy getReplicationRouterConnectionProxy() throws RemoteException
getReplicationRouterConnectionProxy
in interface IRemoteSpace
RemoteException
public NIODetails getNIODetails()
NIOInfoProvider
getNIODetails
in interface NIOInfoProvider
public NIOStatistics getNIOStatistics()
NIOInfoProvider
getNIOStatistics
in interface NIOInfoProvider
public void enableLRMIMonitoring() throws RemoteException
NIOInfoProvider
NIOInfoProvider.fetchLRMIMonitoringDetails()
enableLRMIMonitoring
in interface NIOInfoProvider
RemoteException
public void disableLRMIMonitoring() throws RemoteException
NIOInfoProvider
NIOInfoProvider.enableLRMIMonitoring()
disableLRMIMonitoring
in interface NIOInfoProvider
RemoteException
public LRMIMonitoringDetails fetchLRMIMonitoringDetails() throws RemoteException
NIOInfoProvider
NIOInfoProvider.enableLRMIMonitoring()
fetchLRMIMonitoringDetails
in interface NIOInfoProvider
RemoteException
public long getCurrentTimestamp()
getCurrentTimestamp
in interface OSInfoProvider
public OSDetails getOSDetails()
getOSDetails
in interface OSInfoProvider
public OSStatistics getOSStatistics()
getOSStatistics
in interface OSInfoProvider
public JVMDetails getJVMDetails()
getJVMDetails
in interface JVMInfoProvider
public JVMStatistics getJVMStatistics()
getJVMStatistics
in interface JVMInfoProvider
public void runGc()
runGc
in interface JVMInfoProvider
public String[] getZones()
getZones
in interface GridZoneProvider
public boolean isStatisticsAvailable()
StatisticsAdmin
isStatisticsAvailable
in interface StatisticsAdmin
true
if space statistics is availablepublic String[] getStatisticsStringArray() throws StatisticsNotAvailable
StatisticsAdmin
getStatisticsStringArray
in interface StatisticsAdmin
StatisticsNotAvailable
- when space statistics are not availablepublic long getStatisticsSamplingRate() throws StatisticsNotAvailable
StatisticsAdmin
getStatisticsSamplingRate
in interface StatisticsAdmin
StatisticsNotAvailable
- when space statistics are not availablepublic void setStatisticsSamplingRate(long rate) throws StatisticsNotAvailable
StatisticsAdmin
setStatisticsSamplingRate
in interface StatisticsAdmin
rate
- the rate to sample the space for statisticsStatisticsNotAvailable
- when space statistics are not availablepublic Map<Integer,StatisticsContext> getStatistics() throws StatisticsNotAvailable
StatisticsAdmin
StatisticsContext
objects for all filter
operation codes.getStatistics
in interface StatisticsAdmin
StatisticsContext
StatisticsNotAvailable
- when space statistics are not availablepublic StatisticsContext getStatistics(int operationCode) throws StatisticsNotAvailable
StatisticsAdmin
StatisticsContext
for specific
filter operation code.getStatistics
in interface StatisticsAdmin
operationCode
- filter operation code defined in FilterOperationCodes
StatisticsNotAvailable
- when space statistics are not availableFilterOperationCodes
public Map<Integer,StatisticsContext> getStatistics(Integer[] operationCodes) throws StatisticsNotAvailable
StatisticsAdmin
StatisticsContext
objects for passed specific
filter operation codes.getStatistics
in interface StatisticsAdmin
operationCodes
- filter array of operation codes defined in FilterOperationCodes
StatisticsContext
StatisticsNotAvailable
- when space statistics are not availablepublic StatisticsHolder getHolder()
getHolder
in interface StatisticsAdmin
public Map<String,Object> getMetricSnapshots(Collection<String> prefixes) throws RemoteException
getMetricSnapshots
in interface StatisticsAdmin
prefixes
- collection of metrics prefixesRemoteException
public SpaceRuntimeInfo getRuntimeInfo() throws RemoteException
IRemoteJSpaceAdmin
SpaceRuntimeInfo
.
Usage:
SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo();
List classNames = runtime.m_ClassNames;
List numOfEntries = runtime.m_NumOFEntries;
getRuntimeInfo
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic SpaceRuntimeInfo getRuntimeInfo(String className) throws RemoteException
IRemoteJSpaceAdmin
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;
getRuntimeInfo
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic SpaceConfig getConfig()
IRemoteJSpaceAdmin
SpaceConfig
of this space.
Usage:
SpaceConfig config = spaceAdmin.getConfig();
if (config != null)
boolean isClustered = config.m_isClustered;
getConfig
in interface IRemoteJSpaceAdmin
public void start() throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.start();
start
in interface IInternalRemoteJSpaceAdmin
RemoteException
- - Failed to start space.SpaceAlreadyStartedException
- - The space is already startedpublic void startInternal() throws RemoteException
RemoteException
public void stop() throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.stop();
stop
in interface IInternalRemoteJSpaceAdmin
RemoteException
- - Failed to stop space.SpaceAlreadyStoppedException
- - The space is already stoppedpublic void stopInternal() throws RemoteException
RemoteException
public 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 IInternalRemoteJSpaceAdmin
RemoteException
- Failed to restart space.public SpaceInstanceRemoteClassLoaderInfo getSpaceInstanceRemoteClassLoaderInfo()
IRemoteJSpaceAdmin
getSpaceInstanceRemoteClassLoaderInfo
in interface IRemoteJSpaceAdmin
public Object[] getReplicationStatus() throws RemoteException
getReplicationStatus
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic ClusterPolicy getClusterPolicy()
IRemoteJSpaceAdmin
getClusterPolicy
in interface IRemoteJSpaceAdmin
public 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 IRemoteJSpaceAdmin
className
- - 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 IRemoteJSpaceAdmin
className
- - name of class to delete.RemoteException
- if a communication error occursDropClassException
- Failed to drop desired class.public void directDropCLassForAllProxies(String className)
public int getState()
IRemoteJSpaceAdmin
getState
in interface IRemoteJSpaceAdmin
ISpaceState
public void disableStub() throws RemoteException
IInternalRemoteJSpaceAdmin
disableStub
in interface IInternalRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic RuntimeHolder getRuntimeHolder() throws RemoteException
getRuntimeHolder
in interface IInternalRemoteJSpaceAdmin
RemoteException
public boolean isStartedWithinGSC()
isStartedWithinGSC
in interface IInternalRemoteJSpaceAdmin
public 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 IInternalRemoteJSpaceAdmin
remoteUrl
- 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 IInternalRemoteJSpaceAdmin
remoteUrl
- 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 IInternalRemoteJSpaceAdmin
remoteProxy
- 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
IInternalRemoteJSpaceAdmin
getTransactionsInfo
in interface IInternalRemoteJSpaceAdmin
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
RemoteException
- if a communication error occurspublic int countTransactions(int type, int status) throws RemoteException
countTransactions
in interface IInternalRemoteJSpaceAdmin
RemoteException
public List<TemplateInfo> getTemplatesInfo(String className) throws RemoteException
IInternalRemoteJSpaceAdmin
getTemplatesInfo
in interface IInternalRemoteJSpaceAdmin
className
- name of the class to searchRemoteException
public List<ITransportConnection> getConnectionsInfo() throws RemoteException
getConnectionsInfo
in interface IInternalRemoteJSpaceAdmin
RemoteException
public int countIncomingConnections() throws RemoteException
countIncomingConnections
in interface IInternalRemoteJSpaceAdmin
RemoteException
public List<UnderTxnLockedObject> getLockedObjects(Transaction txn) throws RemoteException
getLockedObjects
in interface IInternalRemoteJSpaceAdmin
txn
- - the Transaction that locks the Objects.RemoteException
public SpaceMode getSpaceMode()
IInternalRemoteJSpaceAdmin
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
.
getSpaceMode
in interface IInternalRemoteJSpaceAdmin
SpaceMode
of the space.public boolean isPrimary()
public boolean isBackup()
public SpaceMode addSpaceModeListener(ISpaceModeListener listener)
IInternalRemoteJSpaceAdmin
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.
addSpaceModeListener
in interface IInternalRemoteJSpaceAdmin
listener
- a listener to be called back on space mode changes.SpaceMode
of the space.ISpaceModeListener
,
SpaceMode
public void removeSpaceModeListener(ISpaceModeListener listener)
IInternalRemoteJSpaceAdmin
removeSpaceModeListener
in interface IInternalRemoteJSpaceAdmin
listener
- 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 IInternalRemoteJSpaceAdmin
className
- - 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 IInternalRemoteJSpaceAdmin
className
- - The name of the class to retrieve the information from.RemoteException
- if a communication error occurspublic void forceMoveToPrimary() throws RemoteException
IInternalRemoteJSpaceAdmin
forceMoveToPrimary
in interface IInternalRemoteJSpaceAdmin
RemoteException
public String getReplicationDump()
getReplicationDump
in interface IInternalRemoteJSpaceAdmin
public int flushRedoLogToStorage() throws RemoteException
IInternalRemoteJSpaceAdmin
flushRedoLogToStorage
in interface IInternalRemoteJSpaceAdmin
RemoteException
public 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 IInternalRemoteJSpaceAdmin
RemoteException
public Map<String,LocalViewDetails> getLocalViewDetails() throws RemoteException
getLocalViewDetails
in interface IInternalRemoteJSpaceAdmin
RemoteException
public boolean isLocalCache()
public SpaceCopyStatus spaceCopy(String remoteUrl, Object template, boolean includeNotifyTemplates, int chunkSize)
spaceCopy
in interface IRemoteJSpaceAdmin
remoteUrl
- 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 IRemoteJSpaceAdmin
public void discarded(DiscoveryEvent event)
DiscoveryListener
discarded
in interface DiscoveryListener
event
- the event that describes the discarded registrarspublic void discovered(DiscoveryEvent event)
DiscoveryListener
discovered
in interface DiscoveryListener
event
- the event that describes the discovered registrarspublic byte[] getClusterConfigFile() throws RemoteException
IInternalRemoteJSpaceAdmin
getClusterConfigFile
in interface IInternalRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic void setClusterConfigFile(byte[] config) throws RemoteException
IInternalRemoteJSpaceAdmin
setClusterConfigFile
in interface IInternalRemoteJSpaceAdmin
config
- byte representation of the configuration fileRemoteException
- if a communication error occursprotected void AppendInitialLookupAttributes(List<Entry> lookupAttributes) throws ServiceRegistrationException
AppendInitialLookupAttributes
in class AbstractGigaSpacesService
ServiceRegistrationException
public void demote(long maxSuspendTime, TimeUnit unit, SpaceContext sc) throws DemoteFailedException, RemoteException
IRemoteSpace
demote
in interface IRemoteSpace
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.DemoteFailedException
RemoteException
public void waitForDrain(long timeoutMs, long minTimeToWait, boolean isBackupOnly, org.slf4j.Logger logger) throws TimeoutException
TimeoutException
public SuspendType addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdmin
SuspendTypeChangedInternalListener
suspend type changes.addSpaceSuspendTypeListener
in interface IInternalRemoteJSpaceAdmin
listener
- - SuspendTypeChangedInternalListener
that will receive notification when a space suspend type changes (SuspendType
)public void removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdmin
removeSpaceSuspendTypeListener
in interface IInternalRemoteJSpaceAdmin
listener
- - SuspendTypeChangedInternalListener
that will stop receiving notification when a space suspend type changes (SuspendType
)public void updateClusterInfo()
IRemoteJSpaceAdmin
updateClusterInfo
in interface IRemoteJSpaceAdmin
public String getPuName()
public AttributeStore getAttributeStore()
public void clearBroadcastTables()
public boolean pullBroadcastTables()
Copyright © GigaSpaces.