| Constructor and Description |
|---|
PageMemoryNoStoreImpl(IgniteLogger log,
DirectMemoryProvider directMemoryProvider,
GridCacheSharedContext<?,?> sharedCtx,
int pageSize,
DataRegionConfiguration dataRegionCfg,
LongAdderMetric totalAllocatedPagesMetric,
boolean trackAcquiredPages) |
| Constructor and Description |
|---|
LazyDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
LazyMvccDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext<K,V> |
GridCacheSharedManagerAdapter.cctx
Context.
|
protected GridCacheSharedContext |
IgniteCacheOffheapManagerImpl.ctx |
protected GridCacheSharedContext |
GridCachePreloaderAdapter.ctx |
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheSharedContext<K,V> |
GridCacheSharedManagerAdapter.context() |
<K,V> GridCacheSharedContext<K,V> |
GridCacheProcessor.context() |
GridCacheSharedContext<K,V> |
GridCacheContext.shared() |
GridCacheSharedContext |
CacheGroupContext.shared() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheIoManager.addOrderedCacheGroupHandler(GridCacheSharedContext cctx,
Object topic,
IgniteBiInClosure<UUID,? extends GridCacheGroupIdMessage> c) |
void |
GridCacheIoManager.addOrderedCacheHandler(GridCacheSharedContext cctx,
Object topic,
IgniteBiInClosure<UUID,? extends GridCacheIdMessage> c) |
void |
ExchangeActions.completeRequestFutures(GridCacheSharedContext ctx,
Throwable err) |
void |
GridCacheMessage.finishUnmarshal(GridCacheSharedContext 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 |
GridChangeGlobalStateMessageResponse.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
static GridCacheContext<?,?> |
GridCacheUtils.firstPartitioned(GridCacheSharedContext<?,?> sctx,
int[] cacheIds) |
static GridCacheContext<?,?> |
GridCacheUtils.firstPartitioned(GridCacheSharedContext<?,?> sctx,
Iterable<Integer> cacheIds) |
static byte[] |
GridCacheUtils.marshal(GridCacheSharedContext ctx,
boolean depEnabled,
Object obj) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo info,
GridCacheSharedContext ctx,
CacheObjectContext cacheObjCtx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo> infos,
GridCacheSharedContext ctx,
CacheObjectContext cacheObjCtx) |
protected void |
GridCacheMessage.marshalTx(Iterable<IgniteTxEntry> txEntries,
GridCacheSharedContext ctx) |
IgniteLogger |
GridCacheMessage.messageLogger(GridCacheSharedContext ctx) |
void |
GridCacheMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridChangeGlobalStateMessageResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareObject(@Nullable Object o,
GridCacheSharedContext ctx) |
void |
GridCacheSharedManagerAdapter.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
GridCacheSharedManager.start(GridCacheSharedContext<K,V> cctx)
Starts manager.
|
void |
IgniteCacheOffheapManager.start(GridCacheSharedContext ctx,
CacheGroupContext grp) |
void |
IgniteCacheOffheapManagerImpl.start(GridCacheSharedContext ctx,
CacheGroupContext grp) |
static <K,V> UUID |
GridCacheUtils.subjectId(IgniteInternalTx tx,
GridCacheSharedContext<K,V> ctx)
Gets subject ID by transaction.
|
protected <T> @Nullable List<T> |
GridCacheMessage.unmarshalCollection(@Nullable Collection<byte[]> byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
protected @Nullable Object[] |
GridCacheMessage.unmarshalInvokeArguments(@Nullable byte[][] byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry> txEntries,
boolean near,
GridCacheSharedContext ctx,
ClassLoader ldr) |
static <K,V> void |
GridCacheUtils.unwindEvicts(GridCacheSharedContext<K,V> ctx) |
void |
ExchangeDiscoveryEvents.warnNoAffinityNodes(GridCacheSharedContext<?,?> cctx) |
| Constructor and Description |
|---|
CachesRegistry(GridCacheSharedContext cctx) |
ExchangeContext(GridCacheSharedContext<?,?> cctx,
boolean crd,
GridDhtPartitionsExchangeFuture fut) |
GridCacheContext(GridKernalContext ctx,
GridCacheSharedContext sharedCtx,
CacheConfiguration cacheCfg,
CacheGroupContext grp,
CacheType cacheType,
AffinityTopologyVersion locStartTopVer,
IgniteUuid deploymentId,
boolean affNode,
boolean updatesAllowed,
boolean statisticsEnabled,
boolean recoveryMode,
CacheCompressionManager compressMgr,
GridCacheEventManager evtMgr,
CacheStoreManager storeMgr,
CacheEvictionManager evictMgr,
GridCacheQueryManager<K,V> qryMgr,
CacheContinuousQueryManager contQryMgr,
CacheDataStructuresManager dataStructuresMgr,
GridCacheTtlManager ttlMgr,
GridCacheDrManager drMgr,
CacheConflictResolutionManager<K,V> rslvrMgr,
CachePluginManager pluginMgr,
GridCacheAffinityManager affMgr) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedLockResponse.finishUnmarshal(GridCacheSharedContext 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 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 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 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 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.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
IgniteLogger |
GridDistributedLockResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedTxPrepareResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedTxFinishResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedUnlockRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridCacheTxRecoveryResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedTxFinishRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedTxPrepareRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDistributedLockRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridCacheTxRecoveryRequest.messageLogger(GridCacheSharedContext ctx) |
void |
GridDistributedLockResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedUnlockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheTtlUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridCacheTxRecoveryFuture(GridCacheSharedContext<?,?> cctx,
IgniteInternalTx tx,
Set<UUID> failedNodeIds,
Map<UUID,Collection<UUID>> txNodes) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
String txLbl) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addNearKey(KeyCacheObject key,
GridCacheSharedContext ctx)
Adds a Near key.
|
void |
GridInvokeValue.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
Unmarshalls invoke value.
|
void |
GridDhtTxPrepareResponse.finishUnmarshal(GridCacheSharedContext 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 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 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 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 |
GridDhtTxFinishResponse.finishUnmarshal(GridCacheSharedContext 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 |
GridDhtTxQueryEnlistRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridDhtTxQueryEnlistResponse.finishUnmarshal(GridCacheSharedContext 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.finishUnmarshal(GridCacheSharedContext 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 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.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxFinishResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxQueryEnlistRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxQueryEnlistResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheSharedContext ctx) |
void |
GridDhtUnlockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected @Nullable Object[] |
GridInvokeValue.unmarshalInvokeArguments(@Nullable byte[][] byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
| Constructor and Description |
|---|
GridDhtAssignmentFetchFuture(GridCacheSharedContext ctx,
int grpId,
AffinityTopologyVersion topVer,
DiscoCache discoCache) |
GridDhtTxFinishFuture(GridCacheSharedContext<K,V> cctx,
GridDhtTxLocalAdapter tx,
boolean commit) |
GridDhtTxLocal(GridCacheSharedContext cctx,
AffinityTopologyVersion topVer,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
int nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash,
@Nullable String lb,
GridNearTxLocal parentTx) |
GridDhtTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
@Nullable UUID subjId,
int taskNameHash) |
GridDhtTxPrepareFuture(GridCacheSharedContext cctx,
GridDhtTxLocalAdapter tx,
long timeout,
int nearMiniId,
Map<IgniteTxKey,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal) |
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
@Nullable UUID subjId,
int taskNameHash,
boolean single,
boolean storeWriteThrough,
@Nullable String txLbl)
This constructor is meant for optimistic transactions.
|
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
boolean storeWriteThrough,
@Nullable String txLbl)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicNearResponse.finishUnmarshal(GridCacheSharedContext 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 |
GridDhtAtomicSingleUpdateRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearAtomicSingleUpdateFilterRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearAtomicSingleUpdateInvokeRequest.finishUnmarshal(GridCacheSharedContext 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.finishUnmarshal(GridCacheSharedContext 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 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 |
GridNearAtomicSingleUpdateRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearAtomicFullUpdateRequest.finishUnmarshal(GridCacheSharedContext 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 ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
IgniteLogger |
GridDhtAtomicAbstractUpdateRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridNearAtomicAbstractUpdateRequest.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDhtAtomicDeferredUpdateResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridNearAtomicUpdateResponse.messageLogger(GridCacheSharedContext ctx) |
IgniteLogger |
GridDhtAtomicUpdateResponse.messageLogger(GridCacheSharedContext ctx) |
void |
GridDhtAtomicNearResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicSingleUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateFilterRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateInvokeRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicSingleUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicFullUpdateRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheSharedContext |
GridDhtPartitionsExchangeFuture.sharedContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheSharedContext 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 |
GridDhtPartitionSupplyMessageV2.finishUnmarshal(GridCacheSharedContext 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 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.finishUnmarshal(GridCacheSharedContext 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 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 |
GridDhtPartitionDemandLegacyMessage.finishUnmarshal(GridCacheSharedContext 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 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 ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
Map<Integer,Map<Integer,Long>> |
GridDhtPartitionsFullMessage.partitionSizes(GridCacheSharedContext ctx)
Returns partition sizes map for all cache groups.
|
void |
GridDhtPartitionsFullMessage.partitionSizes(GridCacheSharedContext ctx,
Map<Integer,Map<Integer,Long>> partsSizes)
Supplies partition sizes map for all cache groups.
|
void |
GridDhtPartitionsFullMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionSupplyMessageV2.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionDemandMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionDemandLegacyMessage.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
ReadWriteLock busyLock,
GridDhtPartitionExchangeId exchId,
ExchangeActions exchActions,
CacheAffinityChangeMessage affChangeMsg) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtLocalPartition |
GridDhtPartitionTopologyImpl.PartitionFactory.create(GridCacheSharedContext ctx,
CacheGroupContext grp,
int id) |
| Constructor and Description |
|---|
GridClientPartitionTopology(GridCacheSharedContext<?,?> cctx,
DiscoCache discoCache,
int grpId,
int parts,
Object similarAffKey) |
GridDhtLocalPartition(GridCacheSharedContext ctx,
CacheGroupContext grp,
int id,
boolean recovery) |
GridDhtPartitionsStateValidator(GridCacheSharedContext<?,?> cctx)
Constructor.
|
GridDhtPartitionTopologyImpl(GridCacheSharedContext ctx,
CacheGroupContext grp) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext<?,?> |
GridNearTxPrepareFutureAdapter.cctx
Context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxQueryResultsEnlistRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearSingleGetResponse.finishUnmarshal(GridCacheSharedContext 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 |
GridNearTxQueryEnlistRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearSingleGetRequest.finishUnmarshal(GridCacheSharedContext 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 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 |
GridNearTxEnlistRequest.finishUnmarshal(GridCacheSharedContext 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 |
GridNearTxPrepareResponse.finishUnmarshal(GridCacheSharedContext 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 ctx,
ClassLoader ldr) |
void |
GridNearTxFinishResponse.finishUnmarshal(GridCacheSharedContext 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 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 |
GridNearTxEnlistResponse.finishUnmarshal(GridCacheSharedContext 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 |
GridNearTxQueryEnlistResponse.finishUnmarshal(GridCacheSharedContext 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 |
GridNearTxQueryResultsEnlistRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearSingleGetResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxQueryEnlistRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearSingleGetRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearLockRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxEnlistRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxPrepareResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetRequest.prepareMarshal(GridCacheSharedContext ctx) |
void |
GridNearTxFinishResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxEnlistResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxQueryEnlistResponse.prepareMarshal(GridCacheSharedContext 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 |
CacheDataRowAdapter.initFromDataPage(DataPageIO io,
long pageAddr,
int itemId,
@Nullable CacheGroupContext grp,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData,
boolean skipVer) |
void |
CacheDataRowAdapter.initFromLink(@Nullable CacheGroupContext grp,
GridCacheSharedContext<?,?> sharedCtx,
PageMemory pageMem,
CacheDataRowAdapter.RowData rowData,
boolean skipVer)
Read row from data pages.
|
protected IncompleteObject<?> |
CacheDataRowAdapter.readFragment(GridCacheSharedContext<?,?> sharedCtx,
CacheObjectContext coctx,
ByteBuffer buf,
boolean keyOnly,
boolean readCacheId,
IncompleteObject<?> incomplete,
boolean skipVer) |
protected void |
CacheDataRowAdapter.readFullRow(GridCacheSharedContext<?,?> sharedCtx,
CacheObjectContext coctx,
long addr,
CacheDataRowAdapter.RowData rowData,
boolean readCacheId,
boolean skipVer) |
protected int |
CacheDataRowAdapter.readHeader(GridCacheSharedContext<?,?> sharedCtx,
long addr,
int off,
CacheDataRowAdapter.RowData rowData)
Reads row header (i.e.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,CheckpointEntry.GroupState> |
CheckpointEntry.groupState(GridCacheSharedContext cctx) |
Long |
CheckpointEntry.partitionCounter(GridCacheSharedContext cctx,
int grpId,
int part) |
| Constructor and Description |
|---|
FairFifoPageEvictionTracker(PageMemoryNoStoreImpl pageMem,
DataRegionConfiguration plcCfg,
GridCacheSharedContext sharedCtx) |
Random2LruPageEvictionTracker(PageMemoryNoStoreImpl pageMem,
DataRegionConfiguration plcCfg,
GridCacheSharedContext<?,?> sharedCtx) |
RandomLruPageEvictionTracker(PageMemory pageMem,
DataRegionConfiguration plcCfg,
GridCacheSharedContext<?,?> sharedCtx) |
| Constructor and Description |
|---|
MetaStorage(GridCacheSharedContext<?,?> cctx,
DataRegion dataRegion,
DataRegionMetricsImpl regionMetrics,
boolean readOnly) |
| Constructor and Description |
|---|
PageMemoryImpl(DirectMemoryProvider directMemoryProvider,
long[] sizes,
GridCacheSharedContext<?,?> ctx,
int pageSize,
PageStoreWriter flushDirtyPage,
@Nullable GridInClosure3X<Long,FullPageId,PageMemoryEx> changeTracker,
CheckpointLockStateChecker stateChecker,
DataRegionMetricsImpl memMetrics,
@Nullable PageMemoryImpl.ThrottlingPolicy throttlingPlc,
@NotNull CheckpointWriteProgressSupplier cpProgressProvider) |
| Modifier and Type | Field and Description |
|---|---|
protected @NotNull GridCacheSharedContext |
AbstractWalRecordsIterator.sharedCtx
Shared context for creating serializer of required version and grid name access.
|
| Constructor and Description |
|---|
AbstractWalRecordsIterator(@NotNull IgniteLogger log,
@NotNull GridCacheSharedContext sharedCtx,
@NotNull RecordSerializerFactory serializerFactory,
@NotNull FileIOFactory ioFactory,
int initialReadBufferSize,
SegmentFileInputFactory segmentFileInputFactory) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext |
FsyncFileHandleManagerImpl.cctx
Context.
|
protected GridCacheSharedContext |
FileHandleManagerImpl.cctx
Context.
|
| Modifier and Type | Method and Description |
|---|---|
FileHandleManager |
FileHandleManagerFactory.build(GridCacheSharedContext cctx,
DataStorageMetricsImpl metrics,
boolean mmap,
Supplier<WALPointer> lastWALPtr,
RecordSerializer serializer,
Supplier<FileWriteHandle> currHandleSupplier) |
| Constructor and Description |
|---|
FileHandleManagerImpl(GridCacheSharedContext cctx,
DataStorageMetricsImpl metrics,
boolean mmap,
Supplier<WALPointer> lastWALPtr,
RecordSerializer serializer,
Supplier<FileWriteHandle> currentHandleSupplier,
WALMode mode,
int walBufferSize,
long maxWalSegmentSize,
long fsyncDelay) |
FsyncFileHandleManagerImpl(GridCacheSharedContext cctx,
DataStorageMetricsImpl metrics,
Supplier<WALPointer> ptr,
RecordSerializer serializer,
Supplier<FileWriteHandle> handle,
WALMode mode,
long maxWalSegmentSize,
long fsyncDelay,
int tlbSize) |
| Modifier and Type | Method and Description |
|---|---|
IgniteWalIteratorFactory.IteratorParametersBuilder |
IgniteWalIteratorFactory.IteratorParametersBuilder.sharedContext(GridCacheSharedContext sharedCtx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext |
RecordDataV1Serializer.cctx
Cache shared context.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheSharedContext |
RecordDataV1Serializer.cctx()
Return shared cache context.
|
| Constructor and Description |
|---|
RecordDataV1Serializer(GridCacheSharedContext cctx) |
RecordDataV2Serializer(GridCacheSharedContext cctx)
Create an instance of V2 data serializer.
|
RecordSerializerFactoryImpl(GridCacheSharedContext cctx) |
RecordSerializerFactoryImpl(GridCacheSharedContext cctx,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryRequest.finishUnmarshal(GridCacheSharedContext 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.finishUnmarshal(GridCacheSharedContext 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.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected <T> @Nullable List<T> |
GridCacheQueryResponse.unmarshalCollection0(@Nullable Collection<byte[]> byteCol,
GridCacheSharedContext ctx,
ClassLoader ldr) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheSharedContext<?,?> |
IgniteTxAdapter.cctx
Cache registry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheSharedContext<?,?> |
IgniteTxAdapter.context() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxImplicitSingleStateImpl.awaitLastFuture(GridCacheSharedContext ctx) |
void |
IgniteTxStateImpl.awaitLastFuture(GridCacheSharedContext cctx) |
void |
IgniteTxRemoteStateAdapter.awaitLastFuture(GridCacheSharedContext cctx) |
void |
IgniteTxState.awaitLastFuture(GridCacheSharedContext cctx) |
void |
TxLocksResponse.finishUnmarshal(GridCacheSharedContext 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 |
TxLocksRequest.finishUnmarshal(GridCacheSharedContext ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheSharedContext) method. |
boolean |
IgniteTxImplicitSingleStateImpl.hasInterceptor(GridCacheSharedContext cctx) |
boolean |
IgniteTxStateImpl.hasInterceptor(GridCacheSharedContext cctx) |
boolean |
IgniteTxRemoteStateAdapter.hasInterceptor(GridCacheSharedContext cctx) |
boolean |
IgniteTxState.hasInterceptor(GridCacheSharedContext cctx) |
void |
IgniteTxEntry.marshal(GridCacheSharedContext<?,?> ctx,
boolean transferExpiry) |
void |
IgniteTxImplicitSingleStateImpl.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxStateImpl.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxRemoteStateAdapter.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxState.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
TxLocksResponse.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
TxLocksRequest.prepareMarshal(GridCacheSharedContext ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
@Nullable GridCacheContext |
IgniteTxImplicitSingleStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxStateImpl.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxRemoteStateAdapter.singleCacheContext(GridCacheSharedContext cctx) |
@Nullable GridCacheContext |
IgniteTxState.singleCacheContext(GridCacheSharedContext cctx) |
Collection<CacheStoreManager> |
IgniteTxRemoteSingleStateImpl.stores(GridCacheSharedContext cctx) |
Collection<CacheStoreManager> |
IgniteTxRemoteStateImpl.stores(GridCacheSharedContext cctx) |
Collection<CacheStoreManager> |
IgniteTxImplicitSingleStateImpl.stores(GridCacheSharedContext cctx) |
Collection<CacheStoreManager> |
IgniteTxStateImpl.stores(GridCacheSharedContext cctx) |
Collection<CacheStoreManager> |
IgniteTxState.stores(GridCacheSharedContext cctx) |
boolean |
IgniteTxImplicitSingleStateImpl.storeWriteThrough(GridCacheSharedContext cctx) |
boolean |
IgniteTxStateImpl.storeWriteThrough(GridCacheSharedContext cctx) |
boolean |
IgniteTxRemoteStateAdapter.storeWriteThrough(GridCacheSharedContext cctx) |
boolean |
IgniteTxState.storeWriteThrough(GridCacheSharedContext cctx) |
CacheWriteSynchronizationMode |
IgniteTxImplicitSingleStateImpl.syncMode(GridCacheSharedContext cctx) |
CacheWriteSynchronizationMode |
IgniteTxStateImpl.syncMode(GridCacheSharedContext cctx) |
CacheWriteSynchronizationMode |
IgniteTxRemoteStateAdapter.syncMode(GridCacheSharedContext cctx) |
CacheWriteSynchronizationMode |
IgniteTxState.syncMode(GridCacheSharedContext cctx) |
GridDhtTopologyFuture |
IgniteTxImplicitSingleStateImpl.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxStateImpl.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxRemoteStateAdapter.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
GridDhtTopologyFuture |
IgniteTxState.topologyReadLock(GridCacheSharedContext cctx,
GridFutureAdapter<?> fut) |
void |
IgniteTxImplicitSingleStateImpl.topologyReadUnlock(GridCacheSharedContext cctx) |
void |
IgniteTxStateImpl.topologyReadUnlock(GridCacheSharedContext cctx) |
void |
IgniteTxRemoteStateAdapter.topologyReadUnlock(GridCacheSharedContext cctx) |
void |
IgniteTxState.topologyReadUnlock(GridCacheSharedContext cctx) |
String |
TxDeadlock.toString(GridCacheSharedContext ctx) |
void |
IgniteTxEntry.unmarshal(GridCacheSharedContext<?,?> ctx,
boolean near,
ClassLoader clsLdr)
Unmarshalls entry.
|
void |
IgniteTxRemoteSingleStateImpl.unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.
|
void |
IgniteTxRemoteStateImpl.unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.
|
void |
IgniteTxImplicitSingleStateImpl.unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.
|
void |
IgniteTxStateImpl.unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.
|
void |
IgniteTxState.unwindEvicts(GridCacheSharedContext cctx)
Unwind evicts for caches involved in this transaction.
|
IgniteCheckedException |
IgniteTxImplicitSingleStateImpl.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxStateImpl.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxRemoteStateAdapter.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
IgniteCheckedException |
IgniteTxState.validateTopology(GridCacheSharedContext cctx,
boolean read,
GridDhtTopologyFuture topFut) |
| Constructor and Description |
|---|
IgniteTransactionsImpl(GridCacheSharedContext<K,V> cctx,
@Nullable String lb) |
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean loc,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
@Nullable UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
@Nullable UUID subjId,
int taskNameHash) |
IgniteTxHandler(GridCacheSharedContext ctx) |
IgniteTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
@Nullable UUID subjId,
int taskNameHash) |
PartitionCountersNeighborcastFuture(IgniteInternalTx tx,
GridCacheSharedContext<?,?> cctx) |
TransactionProxyImpl(GridNearTxLocal tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
TransactionProxyRollbackOnlyImpl(GridNearTxLocal tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
TxDeadlockDetection(GridCacheSharedContext<?,?> cctx) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
MvccDataRow.readHeader(GridCacheSharedContext<?,?> sharedCtx,
long addr,
int off,
CacheDataRowAdapter.RowData rowData)
Reads row header (i.e.
|
| Modifier and Type | Method and Description |
|---|---|
static BaselineTopology |
IgniteUtils.getBaselineTopology(@NotNull GridCacheSharedContext cctx) |
static byte[] |
IgniteUtils.marshal(GridCacheSharedContext ctx,
Object obj)
Marshals object to byte array.
|
static <T> T |
IgniteUtils.unmarshal(GridCacheSharedContext ctx,
byte[] arr,
@Nullable ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.0 Release Date : February 27 2020