Interface IgniteTxState
-
- All Known Subinterfaces:
IgniteTxLocalState,IgniteTxRemoteState
- All Known Implementing Classes:
IgniteTxImplicitSingleStateImpl,IgniteTxLocalStateAdapter,IgniteTxRemoteSingleStateImpl,IgniteTxRemoteStateAdapter,IgniteTxRemoteStateImpl,IgniteTxStateImpl
public interface IgniteTxState
-
-
Method Summary
-
-
-
Method Detail
-
implicitSingle
boolean implicitSingle()
- Returns:
- Flag indicating whether transaction is implicit with only one key.
-
firstCacheId
@Nullable @Nullable Integer firstCacheId()
- Returns:
- First tx cache id.
-
cacheIds
@Nullable @Nullable GridIntList cacheIds()
Gets caches ids affected with current tx.- Returns:
- tx cache ids.
-
unwindEvicts
void unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.- Parameters:
cctx- Grid cache shared context.
-
validateTopology
IgniteCheckedException validateTopology(GridCacheSharedContext cctx, boolean read, GridDhtTopologyFuture topFut)
- Parameters:
cctx- Context.read-Trueif validating for a read operation,falsefor write.topFut- Topology future.- Returns:
- Error if validation failed.
-
syncMode
CacheWriteSynchronizationMode syncMode(GridCacheSharedContext cctx)
- Parameters:
cctx- Context.- Returns:
- Write synchronization mode.
-
addActiveCache
void addActiveCache(GridCacheContext cacheCtx, boolean recovery, IgniteTxAdapter tx) throws IgniteCheckedException
- Parameters:
cacheCtx- Context.tx- Transaction.- Throws:
IgniteCheckedException- If cache check failed.
-
topologyReadLock
GridDhtTopologyFuture topologyReadLock(GridCacheSharedContext cctx, GridFutureAdapter<?> fut)
- Parameters:
cctx- Context.fut- Future to finish with error if some cache is stopping.- Returns:
- Topology future.
-
topologyReadUnlock
void topologyReadUnlock(GridCacheSharedContext cctx)
- Parameters:
cctx- Context.
-
storeWriteThrough
boolean storeWriteThrough(GridCacheSharedContext cctx)
- Parameters:
cctx- Context.- Returns:
Trueif transaction is allowed to use store and transactions spans one or more caches with store enabled.
-
hasInterceptor
boolean hasInterceptor(GridCacheSharedContext cctx)
- Parameters:
cctx- Context.- Returns:
Trueif transaction spans one or more caches with configured interceptor.
-
stores
Collection<CacheStoreManager> stores(GridCacheSharedContext cctx)
- Parameters:
cctx- Context.- Returns:
- Configured stores for active caches.
-
onTxEnd
void onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
- Parameters:
cctx- Context.tx- Transaction.commit- Commit flag.
-
entry
@Nullable @Nullable IgniteTxEntry entry(IgniteTxKey key)
- Parameters:
key- Key.- Returns:
- Entry.
-
hasWriteKey
boolean hasWriteKey(IgniteTxKey key)
- Parameters:
key- Key.- Returns:
Trueif tx has write key.
-
readSet
Set<IgniteTxKey> readSet()
- Returns:
- Read entries keys.
-
writeSet
Set<IgniteTxKey> writeSet()
- Returns:
- Write entries keys.
-
writeEntries
Collection<IgniteTxEntry> writeEntries()
- Returns:
- Write entries.
-
readEntries
Collection<IgniteTxEntry> readEntries()
- Returns:
- Read entries.
-
writeMap
Map<IgniteTxKey,IgniteTxEntry> writeMap()
- Returns:
- Write entries map.
-
readMap
Map<IgniteTxKey,IgniteTxEntry> readMap()
- Returns:
- Read entries map.
-
allEntries
Collection<IgniteTxEntry> allEntries()
- Returns:
- All entries.
-
singleWrite
@Nullable @Nullable IgniteTxEntry singleWrite()
- Returns:
- Non-null entry if tx has only one write entry.
-
empty
boolean empty()
- Returns:
Trueif transaction is empty.
-
-