Modifier and Type | Method and Description |
---|---|
XtnEntry |
SpaceEngine.attachToXtn(ServerTransaction txn,
boolean fromReplication)
Join the specified transaction, if not already joined.
|
XtnEntry |
SpaceEngine.getTransaction(ServerTransaction st) |
XtnEntry |
MultipleIdsContext.getXtnEntry() |
Modifier and Type | Method and Description |
---|---|
protected void |
SpaceEngine.attachFromGatewayStateToTransactionIfNeeded(SpaceContext sc,
XtnEntry txnEntry) |
protected void |
SpaceEngine.handleExceptionOnPrepare(TransactionManager mgr,
ServerTransaction st,
boolean supportsTwoPhaseReplication,
XtnEntry xtnEntry) |
void |
FifoGroupsHandler.handleNeedFgOnlyScanOnXtnEnd(Context context,
XtnEntry xtnEntry) |
Constructor and Description |
---|
MultipleIdsContext(ITemplateHolder concentratingTemplate,
int numToAnswer,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
UpdateMultipleContext(ITemplateHolder concentratingTemplate,
IEntryPacket[] entries,
long[] leases,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
UpdateOrWriteMultipleContext(ITemplateHolder concentratingTemplate,
IEntryPacket[] entries,
long[] leases,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
Modifier and Type | Method and Description |
---|---|
XtnEntry |
EntryHolder.getWriteLockOwner() |
XtnEntry |
IEntryHolder.getWriteLockOwner() |
XtnEntry |
ITransactionalEntryData.getWriteLockOwner() |
XtnEntry |
TemplateHolder.getWriteLockOwner() |
XtnEntry |
AbstractEntryData.getWriteLockOwner() |
XtnEntry |
EntryHolder.getXidOriginated() |
XtnEntry |
ISpaceItem.getXidOriginated() |
XtnEntry |
ITransactionalEntryData.getXidOriginated() |
XtnEntry |
TemplateHolder.getXidOriginated() |
XtnEntry |
AbstractEntryData.getXidOriginated() |
Modifier and Type | Method and Description |
---|---|
List<XtnEntry> |
EntryHolder.getReadLockOwners() |
List<XtnEntry> |
IEntryHolder.getReadLockOwners() |
List<XtnEntry> |
TemplateHolder.getReadLockOwners() |
List<XtnEntry> |
ITransactionalEntryData.getReadLocksOwners() |
List<XtnEntry> |
AbstractEntryData.getReadLocksOwners() |
Modifier and Type | Method and Description |
---|---|
void |
EntryHolder.addReadLockOwner(XtnEntry xtn) |
void |
IEntryHolder.addReadLockOwner(XtnEntry xtn) |
void |
ITransactionalEntryData.addReadLockOwner(XtnEntry xtn) |
void |
TemplateHolder.addReadLockOwner(XtnEntry xtn) |
void |
AbstractEntryData.addReadLockOwner(XtnEntry xtn) |
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
IEntryPacket entryPacket,
EntryDataType entryDataType,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
boolean blobStoreEntryHolder) |
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
IEntryPacket entryPacket,
EntryDataType entryDataType,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
int versionID,
boolean keepExpiration,
boolean blobStoreEntryHolder) |
static ITemplateHolder |
TemplateHolderFactory.createTemplateHolder(IServerTypeDesc typeDesc,
ITemplatePacket template,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long SCN,
int templateOperation,
IResponseContext respContext,
boolean returnOnlyUid,
int operationModifiers,
boolean isfifo) |
static ITemplateHolder |
TemplateHolderFactory.createTemplateHolder(IServerTypeDesc typeDesc,
ITemplatePacket template,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long SCN,
int templateOperation,
IResponseContext respContext,
boolean returnOnlyUid,
int operationModifiers,
boolean isfifo,
boolean fromReplication) |
static ITemplateHolder |
TemplateHolderFactory.createUpdateTemplateHolder(IServerTypeDesc typeDesc,
IEntryPacket template,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long SCN,
IResponseContext respContext,
int operationModifiers)
Special builder method for update that uses TemplateHolder instead EntryHolder
|
void |
EntryHolder.removeReadLockOwner(XtnEntry xtn) |
void |
IEntryHolder.removeReadLockOwner(XtnEntry xtn) |
void |
ITransactionalEntryData.removeReadLockOwner(XtnEntry xtn) |
void |
TemplateHolder.removeReadLockOwner(XtnEntry xtn) |
void |
AbstractEntryData.removeReadLockOwner(XtnEntry xtn) |
void |
ITransactionalEntryData.setWriteLockOwner(XtnEntry writeLockOwner) |
void |
AbstractEntryData.setWriteLockOwner(XtnEntry writeLockOwner) |
void |
EntryHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation) |
void |
IEntryHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation) |
void |
TemplateHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation) |
void |
EntryHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation,
boolean createSnapshot) |
void |
IEntryHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation,
boolean createSnapshot) |
void |
TemplateHolder.setWriteLockOwnerAndOperation(XtnEntry writeLockOwner,
int writeLockOperation,
boolean createSnapshot) |
void |
EntryHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
void |
IEntryHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
void |
TemplateHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
void |
ITransactionalEntryData.setXidOriginated(XtnEntry xidOriginated) |
void |
AbstractEntryData.setXidOriginated(XtnEntry xidOriginated) |
Constructor and Description |
---|
ReplicationEntryHolder(IEntryHolder entryHolder,
XtnEntry xtnEntry) |
TemplateHolder(IServerTypeDesc typeDesc,
IEntryPacket packet,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
int templateOperation,
IResponseContext respContext,
int operationModifiers) |
TemplateHolder(IServerTypeDesc typeDesc,
ITemplatePacket packet,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
int templateOperation,
IResponseContext respContext,
boolean returnOnlyUid,
int operationModifiers,
boolean isfifo) |
TemplateHolder(IServerTypeDesc typeDesc,
ITemplatePacket packet,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
int templateOperation,
IResponseContext respContext,
boolean returnOnlyUid,
int operationModifiers,
boolean isfifo,
boolean fromReplication) |
Modifier and Type | Method and Description |
---|---|
XtnEntry |
XtnData.getXtnEntry() |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
CacheManager.associateEntryWithXtn(Context context,
IEntryHolder entryHolder,
ITemplateHolder template,
XtnEntry xtnEntry,
IEntryHolder new_content)
tie an entry with a transaction.
|
void |
CacheManager.commit(Context context,
XtnEntry xtnEntry,
boolean singleParticipant,
boolean anyUpdates,
boolean supportsTwoPhaseReplication) |
int |
CacheManager.count(Context context,
ITemplateHolder template,
XtnEntry xtnFilter) |
void |
CacheManager.disconnectEntryFromXtn(Context context,
IEntryHolder entryHolder,
XtnEntry xtnEntry,
boolean xtnEnd)
disconnect an entry from xtn
|
long |
CacheManager.getFifoXtnNumber(XtnEntry xtnEntry)
get the fifo xtn number of a xtn
|
int |
CacheManager.getNumberOfLockedObjectsUnderTxn(XtnEntry xtnEntry)
used by getTransactionsInfo to retrieve number of Locked Objects
|
void |
CacheManager.handleFifoGroupsCacheOnXtnEnd(Context context,
XtnEntry xtnEntry) |
ISAdapterIterator |
CacheManager.makeUnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType) |
ISAdapterIterator |
CacheManager.makeUnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType,
boolean returnPentries) |
ISAdapterIterator<ITemplateHolder> |
CacheManager.makeUnderXtnTemplatesIter(Context context,
XtnEntry xtnEntry) |
void |
CacheManager.preCommit(Context context,
XtnEntry xtnEntry,
boolean supportsTwoPhaseReplication) |
void |
CacheManager.prepare(Context context,
XtnEntry xtnEntry,
boolean supportsTwoPhaseReplication,
boolean handleReplication,
boolean handleSA) |
void |
CacheManager.prePrepare(XtnEntry xtnEntry)
this method is called by the engine in order to make a "snapshot" of entries needed for
notify.
|
void |
CacheManager.rollback(Context context,
XtnEntry xtnEntry,
boolean alreadyPrepared,
boolean anyUpdates,
boolean supportsTwoPhaseReplication) |
void |
CacheManager.setFifoXtnNumber(XtnEntry xtnEntry,
long fifoXtnNumber)
set the fifo xtn number of a xtn
|
Constructor and Description |
---|
UnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType,
CacheManager cacheManager,
boolean returnPEntry) |
UnderXtnTemplatesIter(Context context,
XtnEntry xtnEntry,
MatchTarget matchTarget,
CacheManager cacheManager) |
XtnData(XtnEntry xtnEntry) |
Modifier and Type | Method and Description |
---|---|
void |
FifoGroupCacheImpl.handleFifoGroupsCacheOnXtnEnd(Context context,
XtnEntry xtnEntry) |
Modifier and Type | Method and Description |
---|---|
void |
Processor.handleCommittedTakenEntries(Context context,
XtnEntry xtnEntry)
handle taken entries under commit .
|
void |
Processor.handleLockedFifoEntriesBeforeXtnEnd(Context context,
XtnEntry xtnEntry,
boolean fromRollback)
before xtn terminated update the last readLock/Writelock fifo xtn number for this entryin
order to have a coherent picture its is called during prepare/commit/rb from the engine main
routines before status change
|
void |
Processor.handleLockedFifoEntriesOnXtnEnd(Context context,
XtnEntry xtnEntry,
boolean fromRollback)
when xtn terminated send the fifo entries to look for for fifo templates its is called during
commit/rb from the engine main routines
|
void |
Processor.handleNewRolledbackEntries(Context context,
XtnEntry xtnEntry)
handle new entries under rollback .
|
boolean |
Processor.handleNotifyFifoInCommit(Context context,
XtnEntry xtnEntry,
boolean fifoNotifyForNonFifoEvents)
this routine is called if the m_CrossXtnsFifoNotifications proprty is set if inserts the
entries to the recentFifo queue of notify this routine is called directly after commit and
not by backgroud thread return true if any entry considered
|
Constructor and Description |
---|
CommitBusPacket(XtnEntry xtnEntry) |
RollbackBusPacket(XtnEntry xtnEntry) |
Modifier and Type | Method and Description |
---|---|
XtnEntry |
EntryXtnInfo.getWriteLockOwner() |
XtnEntry |
EntryXtnInfo.getXidOriginated() |
Modifier and Type | Method and Description |
---|---|
List<XtnEntry> |
EntryXtnInfo.getReadLocksOwners() |
Modifier and Type | Method and Description |
---|---|
void |
EntryXtnInfo.addReadLockOwner(XtnEntry xtn) |
boolean |
EntryXtnInfo.removeReadLockOwner(XtnEntry xtn) |
void |
EntryXtnInfo.setWriteLockOwner(XtnEntry writeLockOwner) |
void |
EntryXtnInfo.setXidOriginated(XtnEntry xidOriginated) |
Modifier and Type | Method and Description |
---|---|
XtnEntry |
TransactionHandler.addTransactionIfAbsent(XtnEntry xtnEntry) |
XtnEntry |
TransactionHandler.attachToXtnGranular(ServerTransaction txn,
boolean fromReplication)
Join the specified transaction, if not already joined.
|
XtnEntry |
TransactionHandler.createTransactionEntry(ServerTransaction txn)
Create new TransactionEntry and add it to the list of managed transactions
|
XtnEntry |
TransactionHandler.createTransactionEntryIfAbsent(ServerTransaction txn,
XtnEntry newXtnEntry)
Create new TransactionEntry and add it to the list of managed transactions if such xtn does
not exist.
|
XtnEntry |
TransactionHandler.getTransactionEntry(ServerTransaction txn)
Get the transaction entry for given transaction.
|
XtnEntry |
Prepared2PCXtnInfo.getXtnEntry() |
Modifier and Type | Method and Description |
---|---|
Map<ServerTransaction,XtnEntry> |
TransactionHandler.getXtnTable() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionHandler.addToPrepared2PCXtns(XtnEntry xtnEntry) |
void |
TransactionHandler.addTransaction(XtnEntry xtnEntry) |
XtnEntry |
TransactionHandler.addTransactionIfAbsent(XtnEntry xtnEntry) |
XtnEntry |
TransactionHandler.createTransactionEntryIfAbsent(ServerTransaction txn,
XtnEntry newXtnEntry)
Create new TransactionEntry and add it to the list of managed transactions if such xtn does
not exist.
|
boolean |
TransactionHandler.isLightTransaction(XtnEntry xtnEntry) |
boolean |
TransactionHandler.lockXtnOnXtnEnd(XtnEntry xtnEntry)
xtn is ending (rollbak/commit) - lock + fifo lock if fifo entries in xtn
|
void |
TransactionHandler.removeTransactionAfterEnd(XtnEntry xtnEntry)
Remove given transaction from handled transactions
|
void |
TransactionHandler.removeUnusedTransaction(XtnEntry xtnEntry,
boolean needLock)
Remove an unused transaction from handled transactions
|
void |
TransactionHandler.unlockXtnOnXtnEnd(XtnEntry xtnEntry,
boolean lockedXtnTable) |
void |
TransactionHandler.xtnLockEntryOnTemplateOperation(Context context,
IEntryHolder eh,
ITemplateHolder th,
XtnEntry alreadyLockedXtn)
/** given an entry + template- perform the xtn locks and set the appropriate
|
void |
TransactionHandler.xtnUnlockEntryOnTemplateOperation(ITemplateHolder th,
XtnEntry alreadyLockedXtn) |
Constructor and Description |
---|
Prepared2PCXtnInfo(XtnEntry xtnEntry,
long basicTimeForPrepare) |
Copyright © GigaSpaces.