| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext<K,V> |
GridCacheSharedManagerAdapter.cctx
Context.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheSharedContext<K,V> |
GridCacheSharedManagerAdapter.context() |
<K,V> GridCacheSharedContext<K,V> |
GridCacheProcessor.context() |
GridCacheSharedContext<K,V> |
GridCacheContext.shared() |
| Modifier and Type | Method and Description |
|---|---|
static Collection<ClusterNode> |
GridCacheUtils.aliveCacheNodes(GridCacheSharedContext ctx,
long topOrder)
Gets alive nodes with at least one cache configured.
|
static Collection<ClusterNode> |
GridCacheUtils.aliveRemoteCacheNodes(GridCacheSharedContext ctx,
long topOrder)
Gets alive remote nodes with at least one cache configured.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheSharedContext ctx,
long topOrder)
Gets all nodes with at least one cache configured.
|
void |
GridCacheMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheEvictionRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheEvictionResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheEntryInfo.marshal(GridCacheSharedContext<K,V> ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheSharedContext ctx,
Object obj) |
protected LinkedHashMap<byte[],Boolean> |
GridCacheMessage.marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map,
GridCacheSharedContext<K,V> ctx) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheSharedContext<K,V> ctx) |
protected <T> byte[][] |
GridCacheMessage.marshalFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheSharedContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheSharedContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheSharedContext<K,V> ctx) |
protected byte[][] |
GridCacheMessage.marshalInvokeArguments(Object[] args,
GridCacheSharedContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalTx(Iterable<IgniteTxEntry<K,V>> txEntries,
GridCacheSharedContext<K,V> ctx) |
protected List<GridCacheValueBytes> |
GridCacheMessage.marshalValuesCollection(Collection<?> col,
GridCacheSharedContext<K,V> ctx) |
static ClusterNode |
GridCacheUtils.oldest(GridCacheSharedContext ctx)
Gets oldest alive node across nodes with at least one cache configured.
|
static ClusterNode |
GridCacheUtils.oldest(GridCacheSharedContext cctx,
long topOrder)
Gets oldest alive node with at least one cache configured for specified topology version.
|
protected void |
GridCacheMessage.prepareFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheSharedContext<K,V> ctx) |
void |
GridCacheMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheSharedContext<K,V> ctx) |
protected void |
GridCacheMessage.prepareObjects(Iterable<?> col,
GridCacheSharedContext<K,V> ctx) |
static Collection<ClusterNode> |
GridCacheUtils.remoteNodes(GridCacheSharedContext ctx)
Gets remote node with at least one cache configured.
|
static Collection<ClusterNode> |
GridCacheUtils.remoteNodes(GridCacheSharedContext ctx,
long topVer)
Gets remote nodes with at least one cache configured.
|
static void |
GridCacheUtils.resetTxContext(GridCacheSharedContext ctx) |
void |
GridCacheSharedManagerAdapter.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManager.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
static <K,V> UUID |
GridCacheUtils.subjectId(IgniteInternalTx<K,V> tx,
GridCacheSharedContext<K,V> ctx)
Gets subject ID by transaction.
|
protected <K1> LinkedHashMap<K1,Boolean> |
GridCacheMessage.unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalCollection(Collection<byte[]> byteCol,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
protected <T> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheMessage.unmarshalFilter(byte[][] byteCol,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
protected Object[] |
GridCacheMessage.unmarshalInvokeArguments(byte[][] byteCol,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry<K,V>> txEntries,
boolean near,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalValueBytesCollection(Collection<GridCacheValueBytes> byteCol,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
static <K,V> void |
GridCacheUtils.unwindEvicts(GridCacheSharedContext<K,V> ctx) |
| Constructor and Description |
|---|
GridCacheContext(GridKernalContext ctx,
GridCacheSharedContext sharedCtx,
CacheConfiguration cacheCfg,
GridCacheEventManager<K,V> evtMgr,
GridCacheSwapManager<K,V> swapMgr,
IgniteCacheSerializationManager<K,V> serMgr,
GridCacheStoreManager<K,V> storeMgr,
GridCacheEvictionManager<K,V> evictMgr,
GridCacheQueryManager<K,V> qryMgr,
CacheContinuousQueryManager<K,V> contQryMgr,
GridCacheAffinityManager<K,V> affMgr,
CacheDataStructuresManager<K,V> dataStructuresMgr,
GridCacheTtlManager<K,V> ttlMgr,
GridCacheDrManager<K,V> drMgr,
CacheJtaManagerAdapter<K,V> jtaMgr) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedBaseMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxFinishRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedUnlockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheTtlUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxPrepareRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedLockResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDistributedLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedBaseMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxFinishRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedUnlockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridCacheOptimisticCheckPreparedTxFuture(GridCacheSharedContext<K,V> cctx,
IgniteInternalTx<K,V> tx,
UUID failedNodeId,
Map<UUID,Collection<UUID>> txNodes) |
GridCacheTxFinishSync(GridCacheSharedContext<K,V> cctx) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<K,V> ctx,
UUID nodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheSharedContext<K,V> ctx)
Adds a Near key.
|
void |
GridDhtUnlockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheSharedContext<K,V> ctx)
Adds a Near key.
|
void |
GridDhtAffinityAssignmentResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtTxPrepareRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtLockResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtUnlockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) |
void |
GridDhtTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridClientPartitionTopology(GridCacheSharedContext<K,V> cctx,
int cacheId,
GridDhtPartitionExchangeId exchId) |
GridDhtTxFinishFuture(GridCacheSharedContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
boolean commit) |
GridDhtTxLocal(GridCacheSharedContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
IgniteUuid nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash) |
GridDhtTxLocalAdapter(GridCacheSharedContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridDhtTxPrepareFuture(GridCacheSharedContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
IgniteUuid nearMiniId,
Map<IgniteTxKey<K>,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) |
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionDemandMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionsSingleMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtForceKeysRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtForceKeysResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionSupplyMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridDhtPartitionDemandMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionSupplyMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsFullMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx,
boolean reassign,
DiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId)
Dummy future created to trigger reassignments if partition
topology changed while preloading.
|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx,
DiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId)
Force preload future created to trigger reassignments if partition
topology changed while preloading.
|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx,
ReadWriteLock busyLock,
GridDhtPartitionExchangeId exchId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearGetResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearTxFinishResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridNearGetRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
void |
GridNearTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxFinishResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) |
| Constructor and Description |
|---|
GridNearTxFinishFuture(GridCacheSharedContext<K,V> cctx,
GridNearTxLocal<K,V> tx,
boolean commit) |
GridNearTxLocal(GridCacheSharedContext<K,V> ctx,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridNearTxPrepareFuture(GridCacheSharedContext<K,V> cctx,
GridNearTxLocal<K,V> tx) |
GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry<K,V>> writeEntries,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheQueryRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
void |
GridCacheQueryResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext<K,V> |
IgniteTxAdapter.cctx
Cache registry.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxEntry.marshal(GridCacheSharedContext<K,V> ctx,
boolean transferExpiry) |
void |
IgniteTxEntry.unmarshal(GridCacheSharedContext<K,V> ctx,
boolean near,
ClassLoader clsLdr)
Unmarshalls entry.
|
| Constructor and Description |
|---|
IgniteTransactionsImpl(GridCacheSharedContext<K,V> cctx) |
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxHandler(GridCacheSharedContext<K,V> ctx) |
IgniteTxLocalAdapter(GridCacheSharedContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
TransactionProxyImpl(IgniteInternalTx<K,V> tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015