Modifier and Type | Field and Description |
---|---|
protected Uid |
StateManager.objectUid |
Modifier and Type | Method and Description |
---|---|
Uid |
StateManager.get_uid() |
Constructor and Description |
---|
AtomicAction(Uid objUid)
AtomicAction constructor with a Uid.
|
StateManager(Uid objUid)
Create object with specific uid.
|
StateManager(Uid objUid,
int ot) |
StateManager(Uid objUid,
int ot,
int om) |
Modifier and Type | Method and Description |
---|---|
static Uid |
Uid.lastResourceUid()
Return a last resource Uid (0:0:0:0:1)
|
static Uid |
Uid.maxUid()
Return the maximum Uid (7fffffffffffffff:7fffffffffffffff:7fffffff:7fffffff:7fffffff)
|
static Uid |
Uid.minUid()
Return the minimum Uid
(-8000000000000000:-8000000000000000:-80000000:-80000000:-80000000)
|
static Uid |
Uid.nullUid()
Return a null Uid (0:0:0:0:0)
|
Modifier and Type | Method and Description |
---|---|
boolean |
Uid.equals(Uid u) |
boolean |
Uid.greaterThan(Uid u) |
boolean |
Uid.lessThan(Uid u) |
boolean |
Uid.notEquals(Uid u) |
Constructor and Description |
---|
Uid(Uid copyFrom)
Create a copy of the specified identifier.
|
Modifier and Type | Method and Description |
---|---|
Uid |
HeuristicNotification.get_uid() |
Uid |
SynchronizationRecord.get_uid() |
Uid |
Reapable.get_uid() |
Uid |
ActionHierarchy.getActionUid(int typeIndex) |
Uid |
ActionHierarchy.getDeepestActionUid()
Returns the transaction id of the most deeply nested transaction.
|
Uid |
BasicAction.getSavingUid() |
Uid |
AbstractRecord.order()
Return the Uid of this abstract record so that it can be ordered in the
intentions list.
|
Uid |
BasicAction.topLevelActionUid()
The following function returns the Uid of the top-level atomic action.
|
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
TwoPhaseCoordinator.getSynchronizations() |
Modifier and Type | Method and Description |
---|---|
boolean |
ActionHierarchy.add(Uid actionId)
Insert new entry growing table as needed.
|
boolean |
ActionHierarchy.add(Uid actionId,
int at)
Add the transaction id at the specified level.
|
void |
CheckedAction.check(boolean isCommit,
Uid actUid,
Hashtable list)
Called during transaction termination if more than one thread is
associated with the transaction.
|
BasicAction |
ActionManager.get(Uid id) |
CheckedAction |
CheckedActionFactory.getCheckedAction(Uid txId,
String actionType)
Return a CheckedAction instance for a transaction.
|
long |
ActionManager.getTimeAdded(Uid id)
Deprecated.
this method no longer serves any useful purpose and will be removed in a future release
|
boolean |
ActionHierarchy.isAncestor(Uid target)
Scan hierarchy looking for a particular Uid starting at deepest
and going up.
|
boolean |
BasicAction.isAncestor(Uid ancestor)
boolean function that checks whether the Uid passed as an argument is the
Uid for an ancestor of the current atomic action.
|
void |
ActionManager.remove(Uid id) |
Constructor and Description |
---|
AbstractRecord(Uid storeUid)
Create a new instance with the specified paramaters.
|
AbstractRecord(Uid storeUid,
String objType,
int otype)
Create a new instance with the specified parameters.
|
BasicAction(Uid objUid)
BasicAction constructor with a Uid.
|
BasicAction(Uid u,
int at)
Recreate the specified transaction.
|
TwoPhaseCoordinator(Uid id) |
TwoPhaseCoordinator(Uid u,
int at) |
Modifier and Type | Method and Description |
---|---|
void |
ReaperMonitor.markedRollbackOnly(Uid txId)
The indicated transaction has been marked as rollback-only by the reaper.
|
void |
ReaperMonitor.rolledBack(Uid txId)
The indicated transaction has been rolled back by the reaper.
|
Modifier and Type | Method and Description |
---|---|
Uid |
ObjectStoreIterator.iterate()
return the Uids from the list one at a time.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ParticipantStore.commit_state(Uid u,
String tn)
Commit the object's state in the object store.
|
int |
RecoveryStore.currentState(Uid u,
String tn) |
boolean |
RecoveryStore.hide_state(Uid u,
String tn)
Hide the object's state in the object store.
|
void |
ObjectStore.initialise(Uid u,
String tn)
Initialise the object store.
|
boolean |
RecoveryStore.isType(Uid u,
String tn,
int st)
Is the current state of the object the same as that provided as the last
parameter?
|
boolean |
ObjectStore.isType(Uid u,
String tn,
int st)
Is the current state of the object the same as that provided as the last
parameter?
|
InputObjectState |
RecoveryStore.read_committed(Uid u,
String tn)
Read the object's committed state.
|
InputObjectState |
ParticipantStore.read_committed(Uid u,
String tn)
Read the object's committed state.
|
InputObjectState |
ParticipantStore.read_uncommitted(Uid u,
String tn)
Read the object's shadowed state.
|
boolean |
TxLog.remove_committed(Uid u,
String tn)
Remove the object's committed state.
|
boolean |
ParticipantStore.remove_uncommitted(Uid u,
String tn)
Remove the object's uncommitted state.
|
boolean |
RecoveryStore.reveal_state(Uid u,
String tn)
Reveal a hidden object's state.
|
boolean |
TxLog.write_committed(Uid u,
String tn,
OutputObjectState buff)
Write a new copy of the object's committed state.
|
boolean |
ParticipantStore.write_uncommitted(Uid u,
String tn,
OutputObjectState buff)
Write a copy of the object's uncommitted state.
|
Modifier and Type | Method and Description |
---|---|
int |
TransactionStatusConnectionManager.getTransactionStatus(String transactionType,
Uid tranUid)
Obtain the transaction status for the specified transaction type
and transaction.
|
int |
TransactionStatusConnectionManager.getTransactionStatus(Uid tranUid)
Obtain the transaction status for the specified transaction.
|
Constructor and Description |
---|
RecoverAtomicAction(Uid rcvUid,
int theStatus)
Re-creates/activates an AtomicAction for the specified
transaction Uid.
|
Modifier and Type | Method and Description |
---|---|
Uid |
OutputObjectState.stateUid() |
Uid |
InputObjectState.stateUid() |
Constructor and Description |
---|
InputObjectState(Uid newUid,
String tName,
byte[] buff) |
OutputObjectState(Uid newUid,
String tName) |
OutputObjectState(Uid newUid,
String tName,
byte[] buffer) |
Modifier and Type | Method and Description |
---|---|
EditableTransaction |
TransactionTypeManager.getTransaction(String type,
Uid u) |
EditableTransaction |
TransactionTypeManager.TransactionTypeMap.getTransaction(Uid u) |
Modifier and Type | Method and Description |
---|---|
Uid |
ObjectStateWrapper.getNewUid() |
Modifier and Type | Method and Description |
---|---|
boolean |
ParticipantStoreBean.commit_state(Uid u,
String tn) |
boolean |
ParticipantStoreBeanMBean.commit_state(Uid u,
String tn) |
int |
RecoveryStoreBean.currentState(Uid u,
String tn) |
int |
RecoveryStoreBeanMBean.currentState(Uid u,
String tn) |
boolean |
RecoveryStoreBean.hide_state(Uid u,
String tn) |
boolean |
RecoveryStoreBeanMBean.hide_state(Uid u,
String tn) |
boolean |
RecoveryStoreBean.isType(Uid u,
String tn,
int st) |
boolean |
RecoveryStoreBeanMBean.isType(Uid u,
String tn,
int st) |
ObjectStateWrapper |
ParticipantStoreBean.read_committed(Uid u,
String tn) |
ObjectStateWrapper |
RecoveryStoreBean.read_committed(Uid u,
String tn) |
ObjectStateWrapper |
RecoveryStoreBeanMBean.read_committed(Uid u,
String tn) |
ObjectStateWrapper |
ParticipantStoreBeanMBean.read_committed(Uid u,
String tn) |
ObjectStateWrapper |
ParticipantStoreBean.read_uncommitted(Uid u,
String tn) |
ObjectStateWrapper |
ParticipantStoreBeanMBean.read_uncommitted(Uid u,
String tn) |
boolean |
TxLogBean.remove_committed(Uid u,
String tn) |
boolean |
TxLogBeanMBean.remove_committed(Uid u,
String tn) |
boolean |
ParticipantStoreBean.remove_uncommitted(Uid u,
String tn) |
boolean |
ParticipantStoreBeanMBean.remove_uncommitted(Uid u,
String tn) |
boolean |
RecoveryStoreBean.reveal_state(Uid u,
String tn) |
boolean |
RecoveryStoreBeanMBean.reveal_state(Uid u,
String tn) |
boolean |
TxLogBean.write_committed(Uid u,
String tn,
OutputObjectStateWrapper buff) |
boolean |
TxLogBeanMBean.write_committed(Uid u,
String tn,
OutputObjectStateWrapper buff) |
boolean |
ParticipantStoreBean.write_uncommitted(Uid u,
String tn,
OutputObjectStateWrapper buff) |
boolean |
ParticipantStoreBeanMBean.write_uncommitted(Uid u,
String tn,
OutputObjectStateWrapper buff) |
Modifier and Type | Method and Description |
---|---|
boolean |
ParticipantStoreProxy.commit_state(Uid u,
String tn) |
int |
RecoveryStoreProxy.currentState(Uid u,
String tn) |
boolean |
RecoveryStoreProxy.hide_state(Uid u,
String tn) |
boolean |
RecoveryStoreProxy.isType(Uid u,
String tn,
int st) |
InputObjectState |
RecoveryStoreProxy.read_committed(Uid u,
String tn) |
InputObjectState |
ParticipantStoreProxy.read_committed(Uid u,
String tn) |
InputObjectState |
ParticipantStoreProxy.read_uncommitted(Uid u,
String tn) |
boolean |
TxLogProxy.remove_committed(Uid u,
String tn) |
boolean |
ParticipantStoreProxy.remove_uncommitted(Uid u,
String tn) |
boolean |
RecoveryStoreProxy.reveal_state(Uid u,
String tn) |
boolean |
TxLogProxy.write_committed(Uid u,
String tn,
OutputObjectState buff) |
boolean |
ParticipantStoreProxy.write_uncommitted(Uid u,
String tn,
OutputObjectState buff) |
Modifier and Type | Method and Description |
---|---|
Uid |
ActionBean.GenericAtomicActionWrapper.get_uid() |
Uid |
ActionBeanWrapperInterface.get_uid()
Deprecated.
|
Uid |
HeaderState.getProcessUid()
Deprecated.
|
Uid |
HeaderState.getTxUid()
Deprecated.
|
Uid |
UidWrapper.getUid()
Deprecated.
|
Uid |
OSEntryBean.getUid()
Deprecated.
|
Uid |
ActionBean.getUid(AbstractRecord rec)
Deprecated.
return the Uid for given AbstractRecord
|
Uid |
ActionBean.GenericAtomicActionWrapper.getUid(AbstractRecord rec) |
Uid |
ActionBeanWrapperInterface.getUid(AbstractRecord rec)
Deprecated.
|
Uid |
OSEntryBean.getUid(AbstractRecord rec)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
UidWrapper |
ObjStoreBrowser.findUid(Uid uid)
Deprecated.
See if the given uid has previously been registered as an MBean
|
Constructor and Description |
---|
HeaderState(String state,
Uid txUid,
Uid processUid,
long birthDate)
Deprecated.
|
LogRecordWrapper(Uid uid)
Deprecated.
|
StateManagerWrapper(RecoveryStore os,
Uid uid,
String type)
Deprecated.
|
UidWrapper(ObjStoreBrowser browser,
String beantype,
String ostype,
String className,
Uid uid)
Deprecated.
|
UidWrapper(ObjStoreBrowser browser,
String beantype,
String ostype,
String className,
Uid uid,
boolean allowRegistration)
Deprecated.
|
UidWrapper(Uid uid)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Uid |
Utility.getProcessUid() |
Modifier and Type | Method and Description |
---|---|
Uid |
Header.getProcessId() |
Uid |
Header.getTxId() |
Modifier and Type | Method and Description |
---|---|
void |
Header.setProcessId(Uid processId) |
void |
Header.setTxId(Uid txId) |
Constructor and Description |
---|
Header(Uid txId,
Uid processId) |
LogWriteStateManager(Uid objUid) |
LogWriteStateManager(Uid objUid,
int ot) |
LogWriteStateManager(Uid objUid,
int ot,
int om) |
Modifier and Type | Method and Description |
---|---|
static Uid |
UidHelper.unpackFrom(InputBuffer buff) |
Modifier and Type | Method and Description |
---|---|
static void |
UidHelper.packInto(Uid u,
OutputBuffer buff) |
Modifier and Type | Method and Description |
---|---|
CheckedAction |
CheckedActionFactoryImple.getCheckedAction(Uid txId,
String actionType)
This implementation returns the same CheckedAction instance for every transaction.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LogStore.commit_state(Uid objUid,
String tName)
Commit a previous write_state operation which was made with the SHADOW
StateType argument.
|
boolean |
CacheStore.commit_state(Uid objUid,
String tName) |
boolean |
ActionStore.commit_state(Uid objUid,
String tName)
Commit a previous write_state operation which was made with the SHADOW
StateType argument.
|
boolean |
ShadowingStore.commit_state(Uid objUid,
String tName)
Commit a previous write_state operation which was made with the SHADOW
StateType argument.
|
boolean |
NullActionStore.commit_state(Uid objUid,
String tName)
Commit a previous write_state operation which was made with the SHADOW
StateType argument.
|
boolean |
VolatileStore.commit_state(Uid u,
String tn)
Commit the object's state in the object store.
|
boolean |
TwoPhaseVolatileStore.commit_state(Uid u,
String tn)
Commit the object's state in the object store.
|
protected boolean |
CacheStore.commitState(Uid objUid,
String tName) |
int |
LogStore.currentState(Uid objUid,
String tName)
Normally returns the current state of the log entry.
|
int |
ActionStore.currentState(Uid objUid,
String tName) |
int |
ShadowingStore.currentState(Uid objUid,
String tName) |
int |
NullActionStore.currentState(Uid objUid,
String tName) |
int |
VolatileStore.currentState(Uid u,
String tn) |
int |
TwoPhaseVolatileStore.currentState(Uid u,
String tn) |
protected String |
LogStore.genPathName(Uid objUid,
String tName,
int ft) |
protected String |
HashedStore.genPathName(Uid objUid,
String tName,
int otype) |
protected String |
FileSystemStore.genPathName(Uid objUid,
String tName,
int ostype) |
protected String |
ShadowingStore.genPathName(Uid objUid,
String tName,
int ft) |
boolean |
LogStore.hide_state(Uid u,
String tn) |
boolean |
ActionStore.hide_state(Uid u,
String tn) |
boolean |
ShadowingStore.hide_state(Uid objUid,
String tName)
Hide/reveal an object regardless of state.
|
boolean |
NullActionStore.hide_state(Uid u,
String tn) |
boolean |
VolatileStore.hide_state(Uid u,
String tn)
Hide the object's state in the object store.
|
boolean |
TwoPhaseVolatileStore.hide_state(Uid u,
String tn)
Hide the object's state in the object store.
|
InputObjectState |
ActionStore.read_committed(Uid storeUid,
String tName) |
InputObjectState |
FileSystemStore.read_committed(Uid storeUid,
String tName) |
InputObjectState |
NullActionStore.read_committed(Uid storeUid,
String tName) |
InputObjectState |
VolatileStore.read_committed(Uid u,
String tn)
Read the object's committed state.
|
InputObjectState |
TwoPhaseVolatileStore.read_committed(Uid u,
String tn)
Read the object's committed state.
|
protected InputObjectState |
LogStore.read_state(Uid u,
String tn,
int s)
Shouldn't be called during normal execution only during recovery.
|
protected InputObjectState |
CacheStore.read_state(Uid objUid,
String tName,
int ft)
Before we look at the disk let's look in the state cache first for the
state, just in case it hasn't been written out to persistent store yet.
|
protected abstract InputObjectState |
FileLockingStore.read_state(Uid u,
String tn,
int s) |
protected abstract InputObjectState |
FileSystemStore.read_state(Uid u,
String tn,
int s) |
protected InputObjectState |
ShadowingStore.read_state(Uid objUid,
String tName,
int ft) |
InputObjectState |
LogStore.read_uncommitted(Uid u,
String tn) |
InputObjectState |
ActionStore.read_uncommitted(Uid u,
String tn) |
InputObjectState |
FileSystemStore.read_uncommitted(Uid storeUid,
String tName) |
InputObjectState |
NullActionStore.read_uncommitted(Uid u,
String tn) |
InputObjectState |
VolatileStore.read_uncommitted(Uid u,
String tn)
Read the object's shadowed state.
|
InputObjectState |
TwoPhaseVolatileStore.read_uncommitted(Uid u,
String tn)
Read the object's shadowed state.
|
boolean |
ActionStore.remove_committed(Uid storeUid,
String tName) |
boolean |
FileSystemStore.remove_committed(Uid storeUid,
String tName) |
boolean |
NullActionStore.remove_committed(Uid storeUid,
String tName) |
boolean |
VolatileStore.remove_committed(Uid u,
String tn)
Remove the object's committed state.
|
boolean |
TwoPhaseVolatileStore.remove_committed(Uid u,
String tn)
Remove the object's committed state.
|
protected boolean |
LogStore.remove_state(Uid u,
String tn,
int s)
Does nothing except indicate that this thread is finished with the log on
behalf of this transaction.
|
protected boolean |
CacheStore.remove_state(Uid objUid,
String name,
int ft) |
protected abstract boolean |
FileLockingStore.remove_state(Uid u,
String tn,
int s) |
protected abstract boolean |
FileSystemStore.remove_state(Uid u,
String tn,
int s) |
protected boolean |
ShadowingStore.remove_state(Uid objUid,
String name,
int ft) |
boolean |
LogStore.remove_uncommitted(Uid u,
String tn) |
boolean |
ActionStore.remove_uncommitted(Uid u,
String tn) |
boolean |
FileSystemStore.remove_uncommitted(Uid storeUid,
String tName) |
boolean |
NullActionStore.remove_uncommitted(Uid u,
String tn) |
boolean |
VolatileStore.remove_uncommitted(Uid u,
String tn)
Remove the object's uncommitted state.
|
boolean |
TwoPhaseVolatileStore.remove_uncommitted(Uid u,
String tn)
Remove the object's uncommitted state.
|
protected boolean |
CacheStore.removeState(Uid objUid,
String name,
int ft) |
boolean |
LogStore.reveal_state(Uid u,
String tn) |
boolean |
ActionStore.reveal_state(Uid u,
String tn) |
boolean |
ShadowingStore.reveal_state(Uid objUid,
String tName) |
boolean |
NullActionStore.reveal_state(Uid u,
String tn) |
boolean |
VolatileStore.reveal_state(Uid u,
String tn)
Reveal a hidden object's state.
|
boolean |
TwoPhaseVolatileStore.reveal_state(Uid u,
String tn)
Reveal a hidden object's state.
|
boolean |
LogStore.write_committed(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
ActionStore.write_committed(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
FileSystemStore.write_committed(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
NullActionStore.write_committed(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
VolatileStore.write_committed(Uid u,
String tn,
OutputObjectState buff)
Write a new copy of the object's committed state.
|
boolean |
TwoPhaseVolatileStore.write_committed(Uid u,
String tn,
OutputObjectState buff)
Write a new copy of the object's committed state.
|
protected boolean |
LogStore.write_state(Uid objUid,
String tName,
OutputObjectState state,
int ft)
write_state saves the ObjectState in a file named by the type and Uid of
the ObjectState.
|
protected boolean |
CacheStore.write_state(Uid objUid,
String tName,
OutputObjectState state,
int ft) |
protected abstract boolean |
FileLockingStore.write_state(Uid u,
String tn,
OutputObjectState buff,
int s) |
protected abstract boolean |
FileSystemStore.write_state(Uid u,
String tn,
OutputObjectState buff,
int s) |
protected boolean |
ShadowingStore.write_state(Uid objUid,
String tName,
OutputObjectState state,
int ft)
write_state saves the ObjectState in a file named by the type and Uid of
the ObjectState.
|
boolean |
LogStore.write_uncommitted(Uid u,
String tn,
OutputObjectState s) |
boolean |
ActionStore.write_uncommitted(Uid u,
String tn,
OutputObjectState s) |
boolean |
FileSystemStore.write_uncommitted(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
NullActionStore.write_uncommitted(Uid u,
String tn,
OutputObjectState s) |
boolean |
VolatileStore.write_uncommitted(Uid u,
String tn,
OutputObjectState buff)
Write a copy of the object's uncommitted state.
|
boolean |
TwoPhaseVolatileStore.write_uncommitted(Uid u,
String tn,
OutputObjectState buff)
Write a copy of the object's uncommitted state.
|
protected boolean |
CacheStore.writeState(Uid objUid,
String tName,
OutputObjectState state,
int ft) |
Modifier and Type | Method and Description |
---|---|
Uid[] |
HornetqJournalStore.getUidsForType(String typeName) |
Modifier and Type | Method and Description |
---|---|
boolean |
HornetqObjectStoreAdaptor.commit_state(Uid u,
String tn)
Commit the object's state in the object store.
|
boolean |
HornetqJournalStore.contains(Uid uid,
String typeName) |
int |
HornetqObjectStoreAdaptor.currentState(Uid u,
String typeName) |
boolean |
HornetqObjectStoreAdaptor.hide_state(Uid u,
String tn)
Hide the object's state in the object store.
|
boolean |
HornetqObjectStoreAdaptor.isType(Uid u,
String tn,
int st)
Is the current state of the object the same as that provided as the last
parameter?
|
InputObjectState |
HornetqObjectStoreAdaptor.read_committed(Uid u,
String typeName)
Read the object's committed state.
|
InputObjectState |
HornetqJournalStore.read_committed(Uid uid,
String typeName)
Read the object's committed state.
|
InputObjectState |
HornetqObjectStoreAdaptor.read_uncommitted(Uid u,
String tn)
Read the object's shadowed state.
|
boolean |
HornetqObjectStoreAdaptor.remove_committed(Uid u,
String typeName)
Remove the object's committed state.
|
boolean |
HornetqJournalStore.remove_committed(Uid uid,
String typeName)
Remove the object's committed state.
|
boolean |
HornetqObjectStoreAdaptor.remove_uncommitted(Uid u,
String tn)
Remove the object's uncommitted state.
|
boolean |
HornetqObjectStoreAdaptor.reveal_state(Uid u,
String tn)
Reveal a hidden object's state.
|
boolean |
HornetqObjectStoreAdaptor.write_committed(Uid u,
String typeName,
OutputObjectState buff)
Write a new copy of the object's committed state.
|
boolean |
HornetqJournalStore.write_committed(Uid uid,
String typeName,
OutputObjectState txData)
Write a new copy of the object's committed state.
|
boolean |
HornetqObjectStoreAdaptor.write_uncommitted(Uid u,
String tn,
OutputObjectState buff)
Write a copy of the object's uncommitted state.
|
Modifier and Type | Method and Description |
---|---|
boolean |
JDBCStore.commit_state(Uid objUid,
String tName) |
boolean |
JDBCImple_driver.commit_state(Uid objUid,
String typeName) |
int |
JDBCStore.currentState(Uid objUid,
String tName) |
int |
JDBCImple_driver.currentState(Uid objUid,
String typeName)
currentState - determine the current state of an object.
|
boolean |
JDBCStore.hide_state(Uid objUid,
String tName) |
boolean |
JDBCImple_driver.hide_state(Uid objUid,
String typeName) |
boolean |
JDBCStore.isType(Uid u,
String tn,
int st)
Is the current state of the object the same as that provided as the last
parameter?
|
InputObjectState |
JDBCStore.read_committed(Uid storeUid,
String tName) |
InputObjectState |
JDBCImple_driver.read_state(Uid objUid,
String typeName,
int stateType) |
InputObjectState |
JDBCStore.read_uncommitted(Uid storeUid,
String tName) |
boolean |
JDBCStore.remove_committed(Uid storeUid,
String tName) |
boolean |
JDBCImple_driver.remove_state(Uid objUid,
String typeName,
int stateType) |
boolean |
JDBCStore.remove_uncommitted(Uid storeUid,
String tName) |
boolean |
JDBCStore.reveal_state(Uid objUid,
String tName) |
boolean |
JDBCImple_driver.reveal_state(Uid objUid,
String typeName) |
boolean |
JDBCStore.write_committed(Uid storeUid,
String tName,
OutputObjectState state) |
boolean |
JDBCImple_driver.write_state(Uid objUid,
String typeName,
OutputObjectState state,
int stateType) |
boolean |
JDBCStore.write_uncommitted(Uid storeUid,
String tName,
OutputObjectState state) |
Modifier and Type | Method and Description |
---|---|
int |
TransactionStatusConnector.getTransactionStatus(String transaction_type,
Uid tranUid)
Retrieve the transaction status for the specified transaction,
attempts to re-establish connection if necessary.
|
boolean |
ExpiredTransactionScanner.moveEntry(Uid newUid) |
static TransactionStatusManagerItem |
TransactionStatusManagerItem.recreate(Uid uid)
Crash Recovery uses this method to recreate a
representation of the Transaction Status Managers
host/port pair contact.
|
static boolean |
TransactionStatusManagerItem.removeThis(Uid pidUid)
Destroy the host/port pair for the specified process Uid.
|
Constructor and Description |
---|
TransactionStatusConnector(String pid,
Uid pidUid)
Recreate TransactionStatusManagerItem and attempt to establish
a connection to the host/port of the TransactionStatusManager.
|
Constructor and Description |
---|
EditableAtomicAction(Uid u) |
Modifier and Type | Method and Description |
---|---|
XARecoveryResource |
XARecoveryResourceManagerImple.getResource(Uid uid) |
XARecoveryResource |
XARecoveryResourceManagerImple.getResource(Uid uid,
XAResource res) |
Constructor and Description |
---|
RecoverConnectableAtomicAction(String type,
Uid rcvUid,
InputObjectState os) |
XARecoveryResourceImple(Uid u) |
XARecoveryResourceImple(Uid u,
XAResource res) |
Modifier and Type | Method and Description |
---|---|
XARecoveryResource |
XARecoveryResourceManagerImple.getResource(Uid uid) |
XARecoveryResource |
XARecoveryResourceManagerImple.getResource(Uid uid,
XAResource res) |
Constructor and Description |
---|
XARecoveryResourceImple(Uid u) |
XARecoveryResourceImple(Uid u,
XAResource res) |
Modifier and Type | Method and Description |
---|---|
Uid |
SynchronizationImple.get_uid() |
Uid |
CommitMarkableResourceRecord.order() |
Uid |
XAResourceRecord.order() |
Constructor and Description |
---|
XAResourceRecord(Uid u) |
Modifier and Type | Method and Description |
---|---|
Uid |
LocalCleanupSynchronization.get_uid() |
Modifier and Type | Method and Description |
---|---|
Uid |
XAResourceRecord.get_uid() |
Constructor and Description |
---|
XAResourceRecord(Uid u) |
Constructor and Description |
---|
JTAXAResourceRecordWrapper(Uid uid) |
Modifier and Type | Method and Description |
---|---|
Uid |
ArjunaTransactionImpleWrapper.getUid(AbstractRecord rec)
Deprecated.
|
Uid |
ServerTransactionWrapper.getUid(AbstractRecord rec) |
Uid |
RecoveredTransactionWrapper.getUid(AbstractRecord rec) |
Constructor and Description |
---|
ArjunaTransactionImpleWrapper(Uid uid)
Deprecated.
|
JTSXAResourceRecordWrapper(Uid uid) |
RecoveredTransactionWrapper(Uid uid) |
ServerTransactionWrapper(Uid uid) |
Modifier and Type | Method and Description |
---|---|
Uid |
TransactionImple.get_uid() |
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
TransactionImple.getSynchronizations() |
static Map<Uid,Transaction> |
TransactionImple.getTransactions() |
Modifier and Type | Method and Description |
---|---|
static TransactionImple |
TransactionImple.getTransaction(Uid id) |
Constructor and Description |
---|
AtomicAction(Uid actId)
Only used by failure recovery to recreate an inflight transaction.
|
Modifier and Type | Method and Description |
---|---|
Uid |
SubordinateTransaction.get_uid() |
Modifier and Type | Method and Description |
---|---|
TransactionImple |
TransactionImporterImple.recoverTransaction(Uid actId)
Used to recover an imported transaction.
|
SubordinateTransaction |
TransactionImporter.recoverTransaction(Uid actId)
Used to recover an imported transaction.
|
Constructor and Description |
---|
SubordinateAtomicAction(Uid actId)
For crash recovery purposes.
|
Constructor and Description |
---|
SubordinateAtomicAction(Uid actId) |
SubordinateAtomicAction(Uid actId,
boolean peekXidOnly) |
TransactionImple(Uid actId)
Used for failure recovery.
|
Modifier and Type | Method and Description |
---|---|
Uid |
TransactionImple.get_uid() |
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
TransactionImple.getSynchronizations() |
static Map<Uid,Transaction> |
TransactionImple.getTransactions() |
Modifier and Type | Method and Description |
---|---|
SubordinateTransaction |
TransactionImporterImple.recoverTransaction(Uid actId) |
Constructor and Description |
---|
SubordinateAtomicTransaction(Uid actId)
Failure recovery constructor.
|
SubordinateAtomicTransaction(Uid actId,
Xid xid,
int timeout) |
TransactionImple(Uid actId)
For crash recovery purposes.
|
Constructor and Description |
---|
ServerTransaction(Uid actId) |
ServerTransaction(Uid actUid,
Xid xid) |
Modifier and Type | Method and Description |
---|---|
static Xid |
XidUtils.getXid(Uid uid,
boolean branch) |
Modifier and Type | Method and Description |
---|---|
Uid |
ControlWrapper.get_uid() |
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
ControlWrapper.getSynchronizations() |
Constructor and Description |
---|
ControlWrapper(Control c,
Uid u) |
Modifier and Type | Method and Description |
---|---|
Uid |
ContextManager.getReceivedCoordinatorUid() |
Modifier and Type | Method and Description |
---|---|
static ServerControl |
ServerFactory.create_subtransaction(Uid actUid,
Coordinator realCoord,
Terminator realTerm,
ServerControl parent) |
static ServerControl |
ServerFactory.create_transaction(Uid u,
Control parentControl,
ArjunaTransactionImple parentImpl,
Coordinator realCoord,
Terminator realTerm,
int time_out) |
static Status |
ServerFactory.getCurrentStatus(Uid uid) |
static Status |
ServerFactory.getOSStatus(Uid u) |
static Status |
ServerFactory.getStatus(Uid u) |
Constructor and Description |
---|
ServerControlWrapper(Control c,
Uid u) |
Modifier and Type | Field and Description |
---|---|
protected Uid |
ServerResource._theUid |
Modifier and Type | Method and Description |
---|---|
Uid |
ServerResource.get_uid() |
Modifier and Type | Method and Description |
---|---|
protected ControlImple |
Interposition.createHierarchy(PropagationContext ctx,
Uid tlUid) |
static boolean |
Interposition.destroy(Uid act) |
ServerNestedAction |
ServerResource.getChild(Uid actUid) |
protected ServerTopLevelAction |
Interposition.present(Uid actUid) |
protected boolean |
Interposition.removeHierarchy(Uid theUid) |
Modifier and Type | Method and Description |
---|---|
static Uid |
OTIDMap.find(otid_t otid) |
Modifier and Type | Method and Description |
---|---|
protected ControlImple |
OSIInterposition.createHierarchy(PropagationContext ctx,
Uid currentUid) |
static boolean |
OTIDMap.remove(Uid uid) |
Modifier and Type | Method and Description |
---|---|
protected ControlImple |
RestrictedInterposition.createHierarchy(PropagationContext ctx,
Uid tlUid) |
Modifier and Type | Method and Description |
---|---|
protected ControlImple |
StrictInterposition.createHierarchy(PropagationContext ctx,
Uid currentUid) |
Modifier and Type | Field and Description |
---|---|
protected Uid |
ControlImple._theUid |
Modifier and Type | Method and Description |
---|---|
Uid |
ControlImple.get_uid()
Used for garbage collection so we can keep a list of controls and delete
local ones.
|
Modifier and Type | Method and Description |
---|---|
Status |
TransactionFactoryImple.getCurrentStatus(Uid u) |
Status |
TransactionFactoryImple.getOSStatus(Uid u) |
Status |
TransactionFactoryImple.getStatus(Uid u) |
Control |
TransactionFactoryImple.getTransaction(Uid u) |
TransactionInfo |
TransactionFactoryImple.getTransactionInfo(Uid u) |
Constructor and Description |
---|
ControlImple(Coordinator coordinator,
Terminator terminator,
Control parentControl,
Uid uid) |
ControlImple(Coordinator coordinator,
Terminator terminator,
Uid uid) |
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
ArjunaTransactionImple.getSynchronizations() |
Modifier and Type | Method and Description |
---|---|
protected AbstractRecord |
ArjunaTransactionImple.createOTSRecord(boolean propagate,
Resource resource,
Coordinator coord,
Uid recCoordUid) |
Constructor and Description |
---|
ArjunaTransactionImple(Uid actUid)
For crash recovery purposes only.
|
ArjunaTransactionImple(Uid actUid,
Control myParent) |
ArjunaTransactionImple(Uid actUid,
Control myParent,
ArjunaTransactionImple parent) |
Modifier and Type | Method and Description |
---|---|
RecoveryCoordinator |
JavaIdlRCManager.makeRC(Uid RCUid,
Uid tranUid,
Uid processUid,
boolean isServerTransaction)
We create a RecoveryCoordinator reference, but without (we think)
actually making the implementation object available to the orb.
|
Constructor and Description |
---|
ServerControl(Uid actUid,
Control parentCon,
ArjunaTransactionImple parentTran,
Coordinator realCoord,
Terminator realTerm) |
Modifier and Type | Method and Description |
---|---|
Uid |
ServerTransaction.getSavingUid() |
Constructor and Description |
---|
ServerTransaction(Uid recoveringActUid)
Used during crash recovery.
|
ServerTransaction(Uid actUid,
Control myParent) |
ServerTransaction(Uid actUid,
Control myParent,
ArjunaTransactionImple parentImpl) |
Modifier and Type | Method and Description |
---|---|
RecoveryCoordinator |
JacOrbRCManager.makeRC(Uid RCUid,
Uid tranUid,
Uid processUid,
boolean isServerTransaction)
We create a RecoveryCoordinator reference, but without (we think)
actually making the implementation object available to the orb.
|
Modifier and Type | Method and Description |
---|---|
RecoveryCoordinator |
JavaIdlRCManager.makeRC(Uid RCUid,
Uid tranUid,
Uid processUid,
boolean isServerTransaction)
We create a RecoveryCoordinator reference, but without (we think)
actually making the implementation object available to the orb.
|
Modifier and Type | Method and Description |
---|---|
static String |
GenericRecoveryCoordinator.makeId(Uid rcUid,
Uid tranUid,
Uid processUid,
boolean isServerTransaction)
Construct a string, to be used somehow in the objectkey (probably)
of a RecoveryCoordinator reference.
|
Constructor and Description |
---|
GenericRecoveryCoordinator(Uid RCUid,
Uid actionUid,
Uid processUid,
boolean isServerTransaction)
Normal constructor.
|
Modifier and Type | Method and Description |
---|---|
Status |
StatusChecker.checkOriginalStatus(Uid transactionUid,
Uid itemUid,
boolean checkTheObjectStore)
Check the status of a transaction when the contact item uid is known.
|
static Status |
StatusChecker.get_current_status(Uid transactionUid,
Uid itemUid)
get the current status in the original process, given the uid of the contact
item (which is the uid of the process).
|
static Status |
StatusChecker.get_status(Uid transactionUid,
Uid itemUid)
get the status in the original process, given the uid of the contact
item (which is the uid of the process)
|
Modifier and Type | Method and Description |
---|---|
RecoveryCoordinator |
RcvCoManager.makeRC(Uid RCUid,
Uid rootActionUid,
Uid processUid,
boolean isServerTransaction)
Make a RecoveryCoordinator IOR.
|
Modifier and Type | Field and Description |
---|---|
protected Uid |
RecoveredTransaction._originalProcessUid |
protected Uid |
RecoveredServerTransaction._originalProcessUid |
Modifier and Type | Method and Description |
---|---|
Uid |
CachedRecoveredTransaction.getTransactionUid() |
Modifier and Type | Method and Description |
---|---|
void |
RecoveredTransaction.addResourceRecord(Uid rcUid,
Resource r)
Allows a new Resource to be added to the transaction.
|
void |
CachedRecoveredTransaction.addResourceRecord(Uid rcUid,
Resource r)
Add a new resource to a recovered transaction.
|
void |
RecoveredServerTransaction.addResourceRecord(Uid rcUid,
Resource r)
Allows a new Resource to be added to the transaction.
|
static void |
TransactionCache.addResourceRecord(Uid actionUid,
String theType,
Uid rcUid,
Resource r)
Add a new resource to a recovered transaction.
|
static Status |
TransactionCache.get_status(Uid actionUid,
String theType)
Get the status of a transaction
|
static Status |
TransactionCache.getCachedStatus(Uid actionUid)
Get the status of a transaction that is already in the cache
|
static Status |
TransactionCache.getOriginalStatus(Uid actionUid,
String theType)
Get the status of a transaction as it is in the original process
(so type is not needed)
NoTransaction means the original process has gone
|
static int |
TransactionCache.getRecoveryStatus(Uid actionUid,
String theType) |
static Object |
RecoveredTransactionReplayer.isPresent(Uid theUid) |
protected void |
ServerTransactionRecoveryModule.recoverTransaction(Uid tranUid) |
static void |
TransactionCache.replayPhase2(Uid actionUid,
String theType)
Replays phase 2 of a transaction.
|
void |
RecoveredTransactionReplayer.swapResource(Uid rcUid,
Resource r)
Swap an old Resource that was registered with the transaction
for a new one.
|
Constructor and Description |
---|
AssumedCompleteHeuristicServerTransaction(Uid actionUid) |
AssumedCompleteHeuristicTransaction(Uid actionUid) |
AssumedCompleteServerTransaction(Uid actionUid) |
AssumedCompleteTransaction(Uid actionUid) |
CachedRecoveredTransaction(Uid actionUid,
String theType) |
RecoveredServerTransaction(Uid actionUid)
actionUid is the local transaction identification for the remote
transaction - the name of the store entry which contains the state of the
server transaction.
|
RecoveredServerTransaction(Uid actionUid,
String changedTypeName)
actionUid is the local transaction identification for the remote
transaction - the name of the store entry which contains the state of the
server transaction.
|
RecoveredTransaction(Uid actionUid) |
RecoveredTransaction(Uid actionUid,
String changedTypeName) |
RecoveredTransactionReplayer(Uid actionUid,
String actionType) |
Modifier and Type | Method and Description |
---|---|
Uid |
SynchronizationRecord.get_uid() |
Uid |
ExtendedResourceRecord.getRCUid() |
Uid |
ResourceRecord.getRCUid() |
Uid |
ExtendedResourceRecord.order() |
Constructor and Description |
---|
ExtendedResourceRecord(boolean propagate,
Uid objUid,
ArjunaSubtranAwareResource theResource,
Coordinator myParent,
Uid recCoordUid,
ArjunaTransactionImple current) |
ResourceRecord(boolean propagate,
Resource theResource,
Coordinator myParent,
Uid recCoordUid,
ArjunaTransactionImple current)
Constructor
|
ResourceRecord(boolean propagate,
Resource theResource,
Uid recCoordUid) |
Modifier and Type | Method and Description |
---|---|
static Uid |
Helper.getUid(UidCoordinator coord) |
Modifier and Type | Method and Description |
---|---|
InputObjectState |
BasicLockStore.read_state(Uid u,
String tName) |
InputObjectState |
BasicPersistentLockStore.read_state(Uid u,
String tName) |
boolean |
BasicLockStore.remove_state(Uid u,
String tName) |
boolean |
BasicPersistentLockStore.remove_state(Uid u,
String tName) |
boolean |
BasicLockStore.write_committed(Uid u,
String tName,
OutputObjectState state) |
boolean |
BasicPersistentLockStore.write_committed(Uid u,
String tName,
OutputObjectState state) |
Constructor and Description |
---|
RecoveredTransactionalObject(Uid objectUid,
String originalType,
ParticipantStore participantStore) |
Modifier and Type | Method and Description |
---|---|
String |
jtaI18NLogger_$logger.get_transaction_arjunacore_inactive(Uid arg0) |
String |
jtaI18NLogger.get_transaction_arjunacore_inactive(Uid arg0) |
void |
jtaI18NLogger_$logger.info_recovery_recoverydelayed(Uid arg0,
String arg1) |
void |
jtaI18NLogger.info_recovery_recoverydelayed(Uid arg0,
String arg1) |
void |
jtaI18NLogger_$logger.warn_recovery_recoveryfailed(Uid arg0,
String arg1) |
void |
jtaI18NLogger.warn_recovery_recoveryfailed(Uid arg0,
String arg1) |
Modifier and Type | Method and Description |
---|---|
Uid |
XARecoveryResource.get_uid() |
Modifier and Type | Method and Description |
---|---|
XARecoveryResource |
XARecoveryResourceManager.getResource(Uid uid) |
XARecoveryResource |
XARecoveryResourceManager.getResource(Uid uid,
XAResource res) |
Modifier and Type | Method and Description |
---|---|
Uid |
Transaction.get_uid() |
Modifier and Type | Method and Description |
---|---|
Map<Uid,String> |
Transaction.getSynchronizations() |
Modifier and Type | Method and Description |
---|---|
static Uid |
XATxConverter.getBranchUid(XID xid) |
Uid |
XidImple.getTransactionUid() |
static Uid |
XATxConverter.getUid(XID xid) |
Modifier and Type | Method and Description |
---|---|
static Xid |
XATxConverter.getXid(Uid uid,
boolean branch,
int formatId) |
static void |
XATxConverter.setBranchUID(XID xid,
Uid uid) |
Constructor and Description |
---|
XidImple(Uid id) |
XidImple(Uid id,
boolean branch,
Integer eisName) |
Modifier and Type | Method and Description |
---|---|
Uid |
AtomicTransaction.get_uid() |
Modifier and Type | Method and Description |
---|---|
static Uid |
Utility.getUid(Control cont)
If this control refers to an JBoss transaction then return its native
Uid representation.
|
static Uid |
Utility.otidToUid(otid_t otid) |
Modifier and Type | Method and Description |
---|---|
static otid_t |
Utility.uidToOtid(Uid theUid) |
Modifier and Type | Method and Description |
---|---|
Uid |
Lock.getCurrentOwner() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
LockManager.doRelease(Uid u,
boolean all) |
boolean |
LockManager.propagate(Uid from,
Uid to)
Change lock ownership as nested action commits.
|
boolean |
LockManager.releaseAll(Uid actionUid)
Clear out all locks for a given action.
|
boolean |
LockManager.releaselock(Uid lockUid)
Release a SINGLE LOCK lock that has the given uid.
|
Constructor and Description |
---|
Lock(Uid storeUid)
This is used when re-initialising a Lock after retrieval from the object
store.
|
LockManager(Uid storeUid) |
LockManager(Uid storeUid,
int ot) |
LockManager(Uid storeUid,
int ot,
int om) |
Modifier and Type | Method and Description |
---|---|
abstract InputObjectState |
LockStore.read_state(Uid u,
String tName) |
abstract boolean |
LockStore.remove_state(Uid u,
String tname)
Remove the state from the lock store.
|
abstract boolean |
LockStore.write_committed(Uid u,
String tName,
OutputObjectState state)
Write the state to the lock store.
|
Modifier and Type | Method and Description |
---|---|
void |
txojI18NLogger_$logger.warn_LockManager_10(Uid arg0,
String arg1) |
void |
txojI18NLogger.warn_LockManager_10(Uid arg0,
String arg1) |
void |
txojI18NLogger_$logger.warn_LockManager_12(Uid arg0,
String arg1) |
void |
txojI18NLogger.warn_LockManager_12(Uid arg0,
String arg1) |
void |
txojI18NLogger_$logger.warn_LockManager_13(Uid arg0,
String arg1) |
void |
txojI18NLogger.warn_LockManager_13(Uid arg0,
String arg1) |
void |
txojI18NLogger_$logger.warn_LockRecord_2(Uid arg0) |
void |
txojI18NLogger.warn_LockRecord_2(Uid arg0) |
void |
txojI18NLogger_$logger.warn_LockRecord_5(Uid arg0) |
void |
txojI18NLogger.warn_LockRecord_5(Uid arg0) |
void |
txojI18NLogger_$logger.warn_LockRecord_7(String arg0,
Uid arg1) |
void |
txojI18NLogger.warn_LockRecord_7(String arg0,
Uid arg1) |
void |
txojI18NLogger_$logger.warn_recovery_RecoveredTransactionalObject_10(Uid arg0,
Throwable arg1) |
void |
txojI18NLogger.warn_recovery_RecoveredTransactionalObject_10(Uid arg0,
Throwable arg1) |
void |
txojI18NLogger_$logger.warn_recovery_RecoveredTransactionalObject_9(Uid arg0,
Throwable arg1) |
void |
txojI18NLogger.warn_recovery_RecoveredTransactionalObject_9(Uid arg0,
Throwable arg1) |
Modifier and Type | Class and Description |
---|---|
class |
GlobalIdImple
This implementation of GlobalId uses the ArjunaCore Uid class.
|
Modifier and Type | Class and Description |
---|---|
class |
CoordinatorIdImple
This implementation of CoordinatorId uses the ArjunaCore Uid class.
|
Modifier and Type | Method and Description |
---|---|
Uid |
SynchronizationRecord.get_uid() |
Constructor and Description |
---|
BACoordinator(Uid recovery) |
CoordinatorIdImple(Uid id) |
ParticipantRecord(Participant theResource,
Uid id)
Constructor.
|
SynchronizationRecord(Synchronization theResource,
Uid id)
Constructor.
|
Constructor and Description |
---|
SubordinateBACoordinator(Uid recovery)
constructor for recovered coordinator
|
Modifier and Type | Method and Description |
---|---|
Uid |
SynchronizationRecord.get_uid() |
Constructor and Description |
---|
ATCoordinator(Uid recovery) |
CoordinatorIdImple(Uid id) |
ParticipantRecord(Participant theResource,
Uid id)
Constructor.
|
SynchronizationRecord(Synchronization theResource,
Uid id)
Constructor.
|
Constructor and Description |
---|
SubordinateATCoordinator(Uid recovery)
constructor for recovered coordinator
|
Constructor and Description |
---|
RecoveringTransaction(Uid uid) |
Transaction(Uid uid) |
Modifier and Type | Method and Description |
---|---|
static void |
OutboundBridgeManager.removeMapping(Uid externalTxId)
Remove the mapping for the given externalTxId.
|
Constructor and Description |
---|
BridgeXAResource(Uid externalTxId,
BridgeWrapper bridgeWrapper)
Create a new XAResource which wraps the subordinate WS-AT transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
txbridgeI18NLogger_$logger.error_ibdp_norecovery(Uid arg0,
Throwable arg1) |
void |
txbridgeI18NLogger.error_ibdp_norecovery(Uid arg0,
Throwable arg1) |
Constructor and Description |
---|
RecoveryATCoordinator(Uid rcvUid)
Re-creates/activates an AtomicAction for the specified
transaction Uid.
|
RecoverySubordinateATCoordinator(Uid rcvUid)
Re-creates/activates an AtomicAction for the specified
transaction Uid.
|
Constructor and Description |
---|
RecoveryBACoordinator(Uid rcvUid)
Re-creates/activates an AtomicAction for the specified
transaction Uid.
|
RecoverySubordinateBACoordinator(Uid rcvUid)
Re-creates/activates an AtomicAction for the specified
transaction Uid.
|
Modifier and Type | Method and Description |
---|---|
void |
XTSATRecoveryManagerImple.addParticipantRecoveryRecord(Uid uid,
ATParticipantRecoveryRecord participantRecoveryRecord)
add a recovered participant record to the table of unrecovered participants which
need to be recreated following recovery
|
abstract void |
XTSATRecoveryManager.addParticipantRecoveryRecord(Uid uid,
ATParticipantRecoveryRecord participantRecoveryRecord)
add a recovered participant record to the table of unrecovered participants which
need to be recreated following recovery
|
boolean |
XTSATRecoveryManagerImple.isParticipantPresent(Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
n.b.
|
abstract boolean |
XTSATRecoveryManager.isParticipantPresent(Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
|
Modifier and Type | Method and Description |
---|---|
void |
XTSBARecoveryManagerImple.addParticipantRecoveryRecord(Uid uid,
BAParticipantRecoveryRecord participantRecoveryRecord)
add a recovered participant record to the table of unrecovered participants which
need to be recreated following recovery
|
abstract void |
XTSBARecoveryManager.addParticipantRecoveryRecord(Uid uid,
BAParticipantRecoveryRecord participantRecoveryRecord)
add a recovered participant record to the table of unrecovered participants which
need to be recreated following recovery
|
boolean |
XTSBARecoveryManagerImple.isParticipantPresent(Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
n.b.
|
abstract boolean |
XTSBARecoveryManager.isParticipantPresent(Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
|
Modifier and Type | Method and Description |
---|---|
Uid |
Container.getIdentifier(T proxy) |
Modifier and Type | Method and Description |
---|---|
T |
Container.clone(T member,
Uid id)
Given an identified for an existing object, create another handle.
|
Constructor and Description |
---|
Transaction(Uid objUid)
AtomicAction constructor with a Uid.
|
Modifier and Type | Method and Description |
---|---|
Uid |
RecoverableContainer.getUidForHandle(T proxy)
Given a real object, return the Uid if it exists in this container.
|
Uid |
RecoverableContainer.getUidForOriginal(T member)
Given a real object, return the Uid if it exists in this container.
|
Modifier and Type | Method and Description |
---|---|
T |
RecoverableContainer.enlist(T member,
Uid id)
Given an identified for an existing object, create another handle.
|
T |
RecoverableContainer.getHandle(Uid reference)
Given a Uid, return the proxy for that instance.
|
T |
PersistentContainer.recreate(T member,
Uid id)
Given a unique identifier, the container will either return an existing handle to the object or
recreate the handle with the same state that existed at the commit of the last transaction to use it.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
OptimisticLockManager.doRelease(Uid u,
boolean all) |
boolean |
OptimisticLockManager.propagate(Uid from,
Uid to) |
Constructor and Description |
---|
OptimisticLock(Uid storeId) |
OptimisticLockManager(Uid u) |
OptimisticLockManager(Uid u,
int objectModel) |
Constructor and Description |
---|
LockManagerProxy(T candidate,
Uid u) |
LockManagerProxy(T candidate,
Uid u,
RecoverableContainer<T> cont) |
OptimisticLockManagerProxy(T candidate,
Uid u) |
OptimisticLockManagerProxy(T candidate,
Uid u,
int om,
RecoverableContainer<T> cont) |
OptimisticLockManagerProxy(T candidate,
Uid u,
RecoverableContainer<T> cont) |
Modifier and Type | Method and Description |
---|---|
Uid |
InvocationHandler.get_uid() |
Constructor and Description |
---|
InvocationHandler(RecoverableContainer<T> cont,
T obj,
Uid u) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.