Modifier and Type | Method and Description |
---|---|
void |
LocalTransactionManagerImpl.abort(long id)
Deprecated.
|
void |
LocalTransactionManagerImpl.abort(long id,
long waitFor)
Deprecated.
|
void |
LocalTransactionManagerImpl.abort(Object xid)
Deprecated.
|
void |
LocalTransactionManagerImpl.abort(Object xid,
long waitFor)
Deprecated.
|
void |
LocalTransactionManagerImpl.commit(long xtnID)
Deprecated.
|
void |
LocalTransactionManagerImpl.commit(long xtnID,
long waitFor)
Deprecated.
|
void |
LocalTransactionManagerImpl.commit(Object xid)
Deprecated.
|
void |
LocalTransactionManagerImpl.commit(Object xid,
long waitFor)
Deprecated.
|
boolean |
LocalTransactionManagerImpl.disJoin(long id,
TransactionParticipant preparedPart)
Deprecated.
|
int |
LocalTransactionManagerImpl.getState(long id)
Deprecated.
|
int |
LocalTransactionManagerImpl.getState(Object id)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction xtn)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(Object id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction xtn)
Deprecated.
|
void |
LocalTransactionManagerImpl.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy)
Deprecated.
|
int |
LocalTransactionManagerImpl.prepare(Object xid)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
GSServerTransaction.abort() |
void |
GSServerTransaction.abort(long l) |
void |
GSServerTransaction.commit() |
void |
GSServerTransaction.commit(long l) |
int |
GSServerTransaction.getState() |
void |
GSServerTransaction.join(TransactionParticipant part,
long crashCount) |
void |
GSServerTransaction.join(TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
protected void |
GSServerTransaction.join(TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName,
Object proxy) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceReplicationTransactionEventHandler.inTransactionCommit(IReplicationInContext context,
ITransactionInContext transactionContext) |
Constructor and Description |
---|
UnknownTransactionConsumeResult(UnknownTransactionException exception) |
Modifier and Type | Method and Description |
---|---|
void |
LRMISpaceImpl.abort(TransactionManager parm1,
long parm2) |
void |
LRMISpaceImpl.abort(TransactionManager parm1,
Object parm2) |
void |
LRMISpaceImpl.commit(TransactionManager parm1,
long parm2) |
void |
LRMISpaceImpl.commit(TransactionManager parm1,
long parm2,
int numOfParticipants) |
void |
LRMISpaceImpl.commit(TransactionManager parm1,
Object parm2) |
void |
LRMISpaceImpl.commit(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
int |
LRMISpaceImpl.prepare(TransactionManager parm1,
long parm2) |
Object |
LRMISpaceImpl.prepare(TransactionManager parm1,
long parm2,
boolean parm3) |
int |
LRMISpaceImpl.prepare(TransactionManager parm1,
Object parm2) |
Object |
LRMISpaceImpl.prepare(TransactionManager parm1,
Object parm2,
boolean parm3) |
int |
LRMISpaceImpl.prepare(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
Object |
LRMISpaceImpl.prepare(TransactionManager parm1,
Object parm2,
int parm3,
boolean parm4) |
int |
LRMISpaceImpl.prepareAndCommit(TransactionManager parm1,
long parm2) |
int |
LRMISpaceImpl.prepareAndCommit(TransactionManager parm1,
Object parm2) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceImpl.abort(TransactionManager mgr,
long id) |
void |
IRemoteSpace.abort(TransactionManager parm1,
Object parm2) |
void |
SpaceImpl.abort(TransactionManager mgr,
Object id) |
void |
SpaceEngine.abort(TransactionManager mgr,
ServerTransaction st,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
SpaceImpl.abortImpl(TransactionManager mgr,
Object id,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
SpaceEngine.abortSA(TransactionManager mgr,
ServerTransaction st,
boolean fromLeaseExpiration,
boolean verifyExpiredXtn,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
SpaceImpl.commit(TransactionManager mgr,
long id) |
void |
SpaceImpl.commit(TransactionManager mgr,
long id,
int numOfParticipants) |
void |
IRemoteSpace.commit(TransactionManager parm1,
Object parm2) |
void |
SpaceImpl.commit(TransactionManager mgr,
Object id) |
void |
IRemoteSpace.commit(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
void |
SpaceImpl.commit(TransactionManager mgr,
Object id,
int numOfParticipants) |
void |
SpaceEngine.commit(TransactionManager mgr,
ServerTransaction st,
boolean supportsTwoPhaseReplication,
OperationID operationID,
boolean mayBeFromReplication) |
void |
SpaceImpl.commitImpl(TransactionManager mgr,
Object id,
int numOfParticipants,
boolean supportsTwoPhaseReplication,
OperationID operationID,
boolean mayBeFromReplication) |
int |
SpaceImpl.prepare(TransactionManager mgr,
long id) |
Object |
IRemoteSpace.prepare(TransactionManager mgr,
long id,
boolean needClusteredProxy) |
Object |
SpaceImpl.prepare(TransactionManager mgr,
long id,
boolean needClusteredProxy) |
int |
IRemoteSpace.prepare(TransactionManager parm1,
Object parm2) |
int |
SpaceImpl.prepare(TransactionManager mgr,
Object id) |
Object |
IRemoteSpace.prepare(TransactionManager parm1,
Object parm2,
boolean needClusteredProxy) |
Object |
SpaceImpl.prepare(TransactionManager mgr,
Object parm2,
boolean needClusteredProxy) |
int |
IRemoteSpace.prepare(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
int |
SpaceImpl.prepare(TransactionManager mgr,
Object id,
int numOfParticipants) |
Object |
IRemoteSpace.prepare(TransactionManager parm1,
Object parm2,
int numOfParticipants,
boolean needClusteredProxy) |
Object |
SpaceImpl.prepare(TransactionManager mgr,
Object parm2,
int numOfParticipants,
boolean needClusteredProxy) |
int |
SpaceEngine.prepare(TransactionManager mgr,
ServerTransaction st,
boolean singleParticipant,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
int |
SpaceImpl.prepareAndCommit(TransactionManager mgr,
long id) |
int |
IRemoteSpace.prepareAndCommit(TransactionManager parm1,
Object parm2) |
int |
SpaceImpl.prepareAndCommit(TransactionManager mgr,
Object id) |
int |
SpaceEngine.prepareAndCommit(TransactionManager mgr,
ServerTransaction st,
OperationID operationID)
Prepare and commit the transaction - called for single participant transaction or transaction
without changes
|
int |
SpaceImpl.prepareAndCommitImpl(TransactionManager mgr,
Object id,
OperationID operationID) |
Modifier and Type | Class and Description |
---|---|
class |
SyncHybridTransactionException |
Modifier and Type | Method and Description |
---|---|
void |
DummyTransactionManager.abort(long id) |
void |
DummyTransactionManager.abort(long id,
long waitFor) |
void |
DummyTransactionManager.abort(Object xid) |
void |
DummyTransactionManager.abort(Object xid,
long waitFor) |
void |
DummyTransactionManager.commit(long id) |
void |
DummyTransactionManager.commit(long id,
long waitFor) |
void |
DummyTransactionManager.commit(Object xid) |
void |
DummyTransactionManager.commit(Object xid,
long waitFor) |
boolean |
DummyTransactionManager.disJoin(long id,
TransactionParticipant preparedPart) |
int |
DummyTransactionManager.getState(long id) |
int |
DummyTransactionManager.getState(Object id) |
void |
DummyTransactionManager.join(long id,
TransactionParticipant part,
long crashCount) |
void |
DummyTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
DummyTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject) |
void |
DummyTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
DummyTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount) |
void |
DummyTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
DummyTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject) |
void |
DummyTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
int |
DummyTransactionManager.prepare(Object xid) |
Modifier and Type | Method and Description |
---|---|
void |
TxnManagerImpl.abort_impl(Object id,
long waitFor) |
void |
TxnMgrProxy.abort(long id) |
void |
TxnManagerImpl.abort(long id) |
void |
TxnMgrProxy.abort(long id,
long waitFor) |
void |
TxnManagerImpl.abort(long id,
long waitFor) |
void |
TxnMgrProxy.abort(Object xid) |
void |
TxnManagerImpl.abort(Object xid) |
void |
TxnMgrProxy.abort(Object xid,
long waitFor) |
void |
TxnManagerImpl.abort(Object xid,
long waitFor) |
void |
TxnMgrProxy.commit(long id) |
void |
TxnManagerImpl.commit(long id) |
void |
TxnMgrProxy.commit(long id,
long waitFor) |
void |
TxnManagerImpl.commit(long id,
long waitFor) |
void |
TxnMgrProxy.commit(Object xid) |
void |
TxnManagerImpl.commit(Object xid) |
void |
TxnMgrProxy.commit(Object xid,
long waitFor) |
void |
TxnManagerImpl.commit(Object xid,
long waitFor) |
boolean |
TxnMgrProxy.disJoin(long id,
TransactionParticipant part) |
boolean |
TxnManagerImpl.disJoin(long id,
TransactionParticipant part) |
boolean |
TxnManagerImpl.disJoin(Object id,
TransactionParticipant part) |
int |
TxnMgrProxy.getState(long id) |
int |
TxnManagerImpl.getState(long id) |
int |
TxnMgrProxy.getState(Object xid) |
int |
TxnManagerImpl.getState(Object id) |
Transaction |
TxnManager.getTransaction(long id)
Retrieves a
Transaction given the transaction's ID. |
Transaction |
TxnManagerImpl.getTransaction(long id)
Method from
TxnManager which produces a Transaction from its ID. |
void |
TxnMgrProxy.join(long id,
TransactionParticipant part,
long crashCount) |
void |
TxnManagerImpl.join(long id,
TransactionParticipant part,
long crashCount) |
void |
TxnMgrProxy.join(long id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
TxnManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
TxnMgrProxy.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject)
Deprecated.
|
void |
TxnManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject) |
void |
TxnMgrProxy.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
TxnManagerImpl.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
TxnMgrProxy.join(Object id,
TransactionParticipant part,
long crashCount) |
void |
TxnManagerImpl.join(Object xid,
TransactionParticipant part,
long crashCount) |
void |
TxnMgrProxy.join(Object id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
TxnManagerImpl.join(Object xid,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
TxnMgrProxy.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject)
Deprecated.
|
void |
TxnManagerImpl.join(Object xid,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject) |
void |
TxnMgrProxy.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
TxnManagerImpl.join(Object xid,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
int |
TxnMgrProxy.prepare(Object xid) |
int |
TxnManagerImpl.prepare(Object xid)
prepare the underlying xtn designated by the rendered xid
|
Modifier and Type | Method and Description |
---|---|
void |
Transaction.abort()
Abort the transaction.
|
void |
Transaction.abort(long waitFor)
Abort the transaction, waiting for participants to be notified of the decision.
|
void |
Transaction.commit()
Commit the transaction.
|
void |
Transaction.commit(long waitFor)
Commit the transaction, waiting for participants to be notified of the decision.
|
NestableTransaction.Created |
NestableTransaction.create(long leaseTime)
Create a new nested transaction, with the current transaction as parent, managed by the same
transaction manager as the current transaction.
|
NestableTransaction.Created |
NestableTransaction.create(NestableTransactionManager mgr,
long leaseTime)
Create a new nested transaction, with the current transaction as parent, managed by the given
transaction manager.
|
Modifier and Type | Method and Description |
---|---|
void |
ServerTransaction.abort() |
void |
ServerTransaction.abort(long waitFor) |
void |
TransactionManager.abort(long id)
Abort the transaction.
|
void |
TransactionManager.abort(long id,
long waitFor)
Abort the transaction, waiting for participants to be notified of the decision.
|
void |
ExtendedTransactionManager.abort(Object xid) |
void |
ExtendedTransactionManager.abort(Object xid,
long waitFor) |
void |
TransactionParticipant.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 |
ServerTransaction.commit() |
void |
ServerTransaction.commit(long waitFor) |
void |
TransactionManager.commit(long id)
Commit the transaction.
|
void |
TransactionManager.commit(long id,
long waitFor)
Commit the transaction, waiting for participants to be notified of the decision.
|
void |
ExtendedTransactionManager.commit(Object xid) |
void |
ExtendedTransactionManager.commit(Object xid,
long waitFor) |
void |
TransactionParticipant.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 |
TransactionParticipant.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. |
NestableTransaction.Created |
NestableServerTransaction.create(long leaseTime) |
NestableTransaction.Created |
NestableServerTransaction.create(NestableTransactionManager mgr,
long leaseTime) |
TransactionManager.Created |
NestableTransactionManager.create(NestableTransactionManager parentMgr,
long parentID,
long lease)
Begin a nested transaction, with the specified transaction as parent.
|
boolean |
ExtendedTransactionManager.disJoin(long id,
TransactionParticipant preparedPart)
Remove a participant that was joined for a first time.
|
int |
ServerTransaction.getState()
Returns the current state of the transaction.
|
int |
TransactionManager.getState(long id)
Returns the current state of the given transaction.
|
int |
ExtendedTransactionManager.getState(Object id) |
void |
TransactionManager.join(long id,
TransactionParticipant part,
long crashCount)
Join a transaction that is managed by this transaction manager.
|
void |
ExtendedTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
ExtendedTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject)
Deprecated.
|
void |
ExtendedTransactionManager.join(long id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
ExtendedTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount) |
void |
ExtendedTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
void |
ExtendedTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject)
Deprecated.
|
void |
ExtendedTransactionManager.join(Object id,
TransactionParticipant part,
long crashCount,
ServerTransaction userXtnObject,
int partitionId,
String clusterName,
Object clusterProxy) |
void |
ServerTransaction.join(TransactionParticipant part,
long crashCount)
Join the transaction.
|
void |
ServerTransaction.join(TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName) |
protected void |
ServerTransaction.join(TransactionParticipant part,
long crashCount,
int partitionId,
String clusterName,
Object proxy) |
void |
ServerTransaction.joinIfNeededAndEmbedded(TransactionParticipant participant)
Deprecated.
|
boolean |
ServerTransaction.joinIfNeededAndEmbedded(TransactionParticipant participant,
int partitionId,
String clusterName,
Object proxy) |
int |
ExtendedTransactionManager.prepare(Object xid)
prepare the underlying xtn designated by the rendered xid
|
int |
TransactionParticipant.prepare(TransactionManager mgr,
long id)
Requests that the participant prepare itself to commit the transaction, and to vote on the
outcome of the transaction.
|
int |
TransactionParticipant.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 . |
void |
NestableTransactionManager.promote(long id,
TransactionParticipant[] parts,
long[] crashCounts,
TransactionParticipant drop)
Promote the listed participants into the specified transaction.
|
void |
NestableServerTransaction.promote(TransactionParticipant[] parts,
long[] crashCounts,
TransactionParticipant drop)
Promote the listed participants (from a subtransaction) into this (the parent) transaction.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractCommitTwoPhaseTask.abortEmbeddedTransaction() |
protected void |
AbstractCommitTwoPhaseTask.commitEmbeddedTransaction() |
protected abstract AbstractMVCCProtocolTaskResult |
AbstractCommitTwoPhaseTask.executeCommitTask() |
Copyright © GigaSpaces.