org.apache.ignite.internal.processors.cache.transactions

Class IgniteTxImplicitSingleStateImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalStateAdapter

org.apache.ignite.internal.processors.cache.transactions.IgniteTxImplicitSingleStateImpl

All Implemented Interfaces:

IgniteTxLocalState, IgniteTxState

public class IgniteTxImplicitSingleStateImpl
extends IgniteTxLocalStateAdapter

Constructor Summary

Constructors

Constructor and Description
IgniteTxImplicitSingleStateImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addActiveCache(GridCacheContext ctx, IgniteTxLocalAdapter tx)
void	addEntry(IgniteTxEntry entry)
Collection<IgniteTxEntry>	allEntries()
void	awaitLastFut(GridCacheSharedContext ctx)
boolean	empty()
IgniteTxEntry	entry(IgniteTxKey key)
Integer	firstCacheId()
boolean	hasInterceptor(GridCacheSharedContext cctx)
boolean	hasNearCache(GridCacheSharedContext cctx)
boolean	hasWriteKey(IgniteTxKey key)
boolean	implicitSingle()
boolean	init(int txSize)
boolean	initialized()
void	onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
Collection<IgniteTxEntry>	readEntries()
Map<IgniteTxKey,IgniteTxEntry>	readMap()
Set<IgniteTxKey>	readSet()
void	seal()
GridCacheContext	singleCacheContext(GridCacheSharedContext cctx)
IgniteTxEntry	singleWrite()
Collection<CacheStoreManager>	stores(GridCacheSharedContext cctx)
boolean	storeUsed(GridCacheSharedContext cctx)
CacheWriteSynchronizationMode	syncMode(GridCacheSharedContext cctx)
GridDhtTopologyFuture	topologyReadLock(GridCacheSharedContext cctx, GridFutureAdapter<?> fut)
void	topologyReadUnlock(GridCacheSharedContext cctx)
String	toString()
IgniteCheckedException	validateTopology(GridCacheSharedContext cctx, GridDhtTopologyFuture topFut)
Collection<IgniteTxEntry>	writeEntries()
Map<IgniteTxKey,IgniteTxEntry>	writeMap()
Set<IgniteTxKey>	writeSet()

Methods inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalStateAdapter

onTxEnd

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IgniteTxImplicitSingleStateImpl

public IgniteTxImplicitSingleStateImpl()

Method Detail

addActiveCache

public void addActiveCache(GridCacheContext ctx,
                  IgniteTxLocalAdapter tx)
                    throws IgniteCheckedException

Parameters:

ctx - Ccntext.

tx - Transaction.

Throws:

IgniteCheckedException - If cache check failed.

singleCacheContext

@Nullable
public GridCacheContext singleCacheContext(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

cctx Non-null cache context if tx has only one active cache.

firstCacheId

@Nullable
public Integer firstCacheId()

Returns:

First tx cache id.

awaitLastFut

public void awaitLastFut(GridCacheSharedContext ctx)

Parameters:

ctx - Awaits for previous async operations on active caches to be completed.

implicitSingle

public boolean implicitSingle()

Returns:

Flag indicating whether transaction is implicit with only one key.

validateTopology

public IgniteCheckedException validateTopology(GridCacheSharedContext cctx,
                                      GridDhtTopologyFuture topFut)

Parameters:

cctx - Context.

topFut - Topology future.

Returns:

Error if validation failed.

syncMode

public CacheWriteSynchronizationMode syncMode(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

Write synchronization mode.

hasNearCache

public boolean hasNearCache(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

True is tx has active near cache.

topologyReadLock

public GridDhtTopologyFuture topologyReadLock(GridCacheSharedContext cctx,
                                     GridFutureAdapter<?> fut)

Parameters:

cctx - Context.

fut - Future to finish with error if some cache is stopping.

Returns:

Topology future.

topologyReadUnlock

public void topologyReadUnlock(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

storeUsed

public boolean storeUsed(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

True if transaction is allowed to use store and transactions spans one or more caches with store enabled.

hasInterceptor

public boolean hasInterceptor(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

True if transaction spans one or more caches with configured interceptor.

stores

public Collection<CacheStoreManager> stores(GridCacheSharedContext cctx)

Parameters:

cctx - Context.

Returns:

Configured stores for active caches.

onTxEnd

public void onTxEnd(GridCacheSharedContext cctx,
           IgniteInternalTx tx,
           boolean commit)

Parameters:

cctx - Context.

tx - Transaction.

commit - Commit flag.

entry

public IgniteTxEntry entry(IgniteTxKey key)

Parameters:

key - Key.

Returns:

Entry.

hasWriteKey

public boolean hasWriteKey(IgniteTxKey key)

Parameters:

key - Key.

Returns:

True if tx has write key.

readSet

public Set<IgniteTxKey> readSet()

Returns:

Read entries keys.

writeSet

public Set<IgniteTxKey> writeSet()

Returns:

Write entries keys.

writeEntries

public Collection<IgniteTxEntry> writeEntries()

Returns:

Write entries.

readEntries

public Collection<IgniteTxEntry> readEntries()

Returns:

Read entries.

writeMap

public Map<IgniteTxKey,IgniteTxEntry> writeMap()

Returns:

Write entries map.

readMap

public Map<IgniteTxKey,IgniteTxEntry> readMap()

Returns:

Read entries map.

empty

public boolean empty()

Returns:

True if transaction is empty.

allEntries

public Collection<IgniteTxEntry> allEntries()

Returns:

All entries.

init

public boolean init(int txSize)

Parameters:

txSize - Transaction size.

Returns:

True if transaction was successfully started.

initialized

public boolean initialized()

Returns:

True if init method was called.

addEntry

public void addEntry(IgniteTxEntry entry)

Parameters:

entry - Entry.

seal

public void seal()

singleWrite

public IgniteTxEntry singleWrite()

Returns:

Non-null entry if tx has only one write entry.

toString

public String toString()

Overrides:

toString in class Object