| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
AffinityFunctionContext.currentTopologyVersion()
Gets current topology version number.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridJobExecuteResponse.getRetryTopologyVersion() |
AffinityTopologyVersion |
GridJobExecuteRequest.getTopVer() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDiagnosticPrepareContext.exchangeInfo(UUID nodeId,
AffinityTopologyVersion topVer,
String msg) |
void |
GridMessageListenHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId,
int[] cacheIds,
int part,
AffinityTopologyVersion topVer,
String execName) |
GridJobExecuteResponse(UUID nodeId,
IgniteUuid sesId,
IgniteUuid jobId,
byte[] gridExBytes,
IgniteException gridEx,
byte[] resBytes,
Object res,
byte[] jobAttrsBytes,
Map<Object,Object> jobAttrs,
boolean isCancelled,
AffinityTopologyVersion retry) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
DiscoveryCustomEvent.affinityTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryCustomEvent.affinityTopologyVersion(AffinityTopologyVersion affTopVer) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
DiscoveryLocalJoinData.joinTopologyVersion() |
AffinityTopologyVersion |
GridDiscoveryManager.topologyVersionEx() |
AffinityTopologyVersion |
DiscoCache.version() |
| Modifier and Type | Method and Description |
|---|---|
List<? extends BaselineNode> |
GridDiscoveryManager.baselineNodes(AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridDiscoveryManager.cacheGroupAffinityNodes(int grpId,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given ID that participate in affinity calculation.
|
Collection<ClusterNode> |
GridDiscoveryManager.cacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name.
|
Map<UUID,Short> |
GridDiscoveryManager.consistentId(AffinityTopologyVersion topVer)
Gets consistentId from history for given topology version.
|
DiscoCache |
DiscoCache.copy(AffinityTopologyVersion ver,
DiscoveryDataClusterState state) |
DiscoCache |
DiscoveryCustomMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
GridDiscoveryManager.createDiscoCacheOnCacheChange(AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates discovery cache after
DynamicCacheChangeBatch received. |
DiscoCache |
GridDiscoveryManager.discoCache(AffinityTopologyVersion topVer)
Gets discovery collection cache from SPI safely guarding against "floating" collections.
|
short |
ConsistentIdMapper.mapToCompactId(AffinityTopologyVersion topVer,
UUID nodeId)
Maps UUID to compact ID for given baseline topology.
|
Map<Short,Collection<Short>> |
ConsistentIdMapper.mapToCompactIds(AffinityTopologyVersion topVer,
Map<UUID,Collection<UUID>> txNodes,
BaselineTopology baselineTop)
Map primary -> backup node compact ID accordingly to baseline topology..
|
UUID |
ConsistentIdMapper.mapToUuid(AffinityTopologyVersion topVer,
short nodeConstId)
Maps UUID to compact ID for given baseline topology.
|
ClusterNode |
GridDiscoveryManager.node(AffinityTopologyVersion topVer,
UUID id)
Gets node from history for given topology version.
|
Map<Short,UUID> |
GridDiscoveryManager.nodeIdMap(AffinityTopologyVersion topVer)
Gets consistentId from history for given topology version.
|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(AffinityTopologyVersion topVer)
Gets all nodes for given topology version.
|
ClusterNode |
GridDiscoveryManager.oldestAliveServerNode(AffinityTopologyVersion topVer) |
void |
CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer,
ClusterNode snd,
T msg) |
Collection<ClusterNode> |
GridDiscoveryManager.remoteAliveNodesWithCaches(AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
List<ClusterNode> |
GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridFailoverContextImpl.affinityTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
int affPartId,
String affCacheName,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridFailoverContextImpl(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
GridLoadBalancerManager loadMgr,
int partId,
String affCacheName,
AffinityTopologyVersion topVer)
Initializes failover context.
|
| Modifier and Type | Field and Description |
|---|---|
static AffinityTopologyVersion |
AffinityTopologyVersion.NONE |
static AffinityTopologyVersion |
AffinityTopologyVersion.ZERO |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridAffinityFunctionContextImpl.currentTopologyVersion()
Gets current topology version number.
|
AffinityTopologyVersion |
GridAffinityAssignmentCache.lastVersion() |
AffinityTopologyVersion |
AffinityTopologyVersion.nextMinorVersion() |
AffinityTopologyVersion |
HistoryAffinityAssignment.topologyVersion() |
AffinityTopologyVersion |
GridAffinityAssignment.topologyVersion() |
AffinityTopologyVersion |
AffinityAssignment.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<AffinityTopologyVersion> |
GridAffinityAssignmentCache.cachedVersions() |
IgniteInternalFuture<AffinityTopologyVersion> |
GridAffinityAssignmentCache.readyFuture(AffinityTopologyVersion topVer)
Gets future that will be completed after topology with version
topVer is calculated. |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer) |
Set<Integer> |
GridAffinityAssignmentCache.backupPartitions(UUID nodeId,
AffinityTopologyVersion topVer)
Get backup partitions for specified node ID.
|
AffinityAssignment |
GridAffinityAssignmentCache.cachedAffinity(AffinityTopologyVersion topVer)
Get cached affinity for specified topology version.
|
List<List<ClusterNode>> |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
ExchangeDiscoveryEvents events,
DiscoCache discoCache)
Calculates affinity cache for given topology version.
|
void |
GridAffinityAssignmentCache.clientEventTopologyChange(DiscoveryEvent evt,
AffinityTopologyVersion topVer)
Copies previous affinity assignment when discovery event does not cause affinity assignment changes
(e.g. client node joins on leaves).
|
int |
AffinityTopologyVersion.compareTo(AffinityTopologyVersion o) |
void |
GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment)
Initializes affinity with given topology version and assignment.
|
void |
GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment,
MvccCoordinator mvccCrd)
Initializes affinity with given topology version and assignment.
|
<K> ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key,
AffinityTopologyVersion topVer)
Maps single key to a node.
|
<K> List<ClusterNode> |
GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName,
K key,
AffinityTopologyVersion topVer)
Map single key to primary and backup nodes.
|
ClusterNode |
GridAffinityProcessor.mapPartitionToNode(String cacheName,
int partId,
AffinityTopologyVersion topVer)
Maps partition to a node.
|
List<ClusterNode> |
GridAffinityAssignmentCache.nodes(int part,
AffinityTopologyVersion topVer)
Gets affinity nodes for specified partition.
|
boolean |
GridAffinityAssignmentCache.primaryChanged(int part,
AffinityTopologyVersion startVer,
AffinityTopologyVersion endVer) |
Set<Integer> |
GridAffinityAssignmentCache.primaryPartitions(UUID nodeId,
AffinityTopologyVersion topVer)
Get primary partitions for specified node ID.
|
AffinityAssignment |
GridAffinityAssignmentCache.readyAffinity(AffinityTopologyVersion topVer) |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.readyAssignments(AffinityTopologyVersion topVer) |
IgniteInternalFuture<AffinityTopologyVersion> |
GridAffinityAssignmentCache.readyFuture(AffinityTopologyVersion topVer)
Gets future that will be completed after topology with version
topVer is calculated. |
void |
GridAffinityProcessor.removeCachedAffinity(AffinityTopologyVersion topVer)
Removes cached affinity instances with affinity topology versions less than
topVer. |
| Constructor and Description |
|---|
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
UserAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
UserProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Field and Description |
|---|---|
protected AffinityTopologyVersion |
GridCacheAdapter.TopologyVersionAwareJob.topVer
Affinity topology version.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<AffinityTopologyVersion> |
GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer)
Gets affinity ready future, a future that will be completed after affinity with given
topology version is calculated.
|
IgniteInternalFuture<AffinityTopologyVersion> |
GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion ver) |
IgniteInternalFuture<AffinityTopologyVersion> |
GridCacheAffinityManager.affinityReadyFuture(long topVer)
Gets affinity ready future, a future that will be completed after affinity with given
topology version is calculated.
|
IgniteInternalFuture<AffinityTopologyVersion> |
GridCacheAffinityManager.affinityReadyFuturex(AffinityTopologyVersion topVer)
Gets affinity ready future that will be completed after affinity with given topology version is calculated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CachePartialUpdateCheckedException.add(Collection<?> failedKeys,
Throwable err,
AffinityTopologyVersion topVer) |
boolean |
GridCacheExplicitLockSpan.addCandidate(AffinityTopologyVersion topVer,
GridCacheMvccCandidate cand)
Adds candidate to a lock span.
|
GridFutureAdapter |
GridCacheMvccManager.addDataStreamerFuture(AffinityTopologyVersion topVer) |
void |
GridCacheMvccManager.addExplicitLock(long threadId,
GridCacheMvccCandidate cand,
AffinityTopologyVersion topVer)
Adds candidate to the list of near local candidates.
|
static Collection<ClusterNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx,
AffinityTopologyVersion topVer)
Gets DHT affinity nodes.
|
IgniteInternalFuture<AffinityTopologyVersion> |
GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer)
Gets affinity ready future, a future that will be completed after affinity with given
topology version is calculated.
|
IgniteInternalFuture<AffinityTopologyVersion> |
GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion ver) |
IgniteInternalFuture<AffinityTopologyVersion> |
GridCacheAffinityManager.affinityReadyFuturex(AffinityTopologyVersion topVer)
Gets affinity ready future that will be completed after affinity with given topology version is calculated.
|
AffinityAssignment |
GridCacheAffinityManager.assignment(AffinityTopologyVersion topVer)
Get affinity assignment for the given topology version.
|
List<List<ClusterNode>> |
GridCacheAffinityManager.assignments(AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.backupByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
Set<Integer> |
GridCacheAffinityManager.backupPartitions(UUID nodeId,
AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridCacheAffinityManager.backupsByKey(Object key,
AffinityTopologyVersion topVer) |
long |
IgniteCacheOffheapManager.cacheEntriesCount(int cacheId,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
long |
IgniteCacheOffheapManagerImpl.cacheEntriesCount(int cacheId,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManager.cacheEntriesIterator(GridCacheContext cctx,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> |
IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
boolean keepBinary) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.cacheIterator(int cacheId,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId,
boolean primary,
boolean backups,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot) |
void |
WalStateManager.changeLocalStatesOnExchangeDone(AffinityTopologyVersion topVer)
Change local WAL state before exchange is done.
|
IgniteInternalFuture<Void> |
GridCacheAtomicFuture.completeFuture(AffinityTopologyVersion topVer)
Gets future that will be completed when it is safe when update is finished on the given version of topology.
|
void |
GridCacheProcessor.completeProxyRestart(Map<String,DynamicCacheChangeRequest> reqs,
AffinityTopologyVersion initVer,
AffinityTopologyVersion doneVer) |
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key) |
static GridCacheUtils.BackupPostProcessingClosure |
GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer,
IgniteLogger log,
GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheExpiryPolicy expiryPlc,
boolean readThrough,
boolean skipVals)
Creates closure that saves initial value to backup partition.
|
DiscoCache |
WalStateAbstractMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
TxTimeoutOnPartitionMapExchangeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeBatch.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsClearMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
DynamicCacheChangeFailureMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheStatisticsModeChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ClientCacheChangeDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
CacheAffinityChangeMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ClientCacheChangeDummyDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishAtomicUpdates(AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishDataStreamerUpdates(AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishExplicitLocks(AffinityTopologyVersion topVer)
Creates a future that will wait for all explicit locks acquired on given topology
version to be released.
|
IgniteInternalFuture<?> |
GridCacheMvccManager.finishKeys(Collection<KeyCacheObject> keys,
int cacheId,
AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishLocks(AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishRemoteTxs(AffinityTopologyVersion topVer)
Creates a future that will wait for finishing all remote transactions (primary -> backup)
with topology version less or equal to
topVer. |
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheProxyImpl.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
IgniteInternalCache.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> javax.cache.processor.EntryProcessorResult<T> |
GridCacheAdapter.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> T |
IgniteCacheProxyImpl.invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
boolean |
GridCacheAffinityManager.keyLocalNode(Object key,
AffinityTopologyVersion topVer) |
void |
GridCachePartitionExchangeManager.mergeExchangesTestWaitVersion(AffinityTopologyVersion exchMergeTestWaitVer,
List mergedEvtsForTest)
For testing only.
|
MvccCoordinator |
GridCacheAffinityManager.mvccCoordinator(AffinityTopologyVersion topVer) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHist,
boolean needOldValue,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHistory,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
IgniteInternalFuture<?> |
GridCacheSharedContext.nextAffinityReadyFuture(AffinityTopologyVersion curVer)
Gets ready future for the next affinity topology version (used in cases when a node leaves grid).
|
protected long |
GridCacheMapEntry.nextPartitionCounter(AffinityTopologyVersion topVer,
boolean primary,
Long primaryCntr) |
List<ClusterNode> |
GridCacheAffinityManager.nodesByKey(Object key,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridCacheAffinityManager.nodesByPartition(int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg,
AffinityTopologyVersion topVer,
ClusterNode node)
Callback invoked from discovery thread when discovery custom message is received.
|
void |
GridCacheProcessor.onDiscoveryEvent(int type,
DiscoveryCustomMessage customMsg,
ClusterNode node,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState state) |
void |
GridCachePartitionExchangeManager.onExchangeDone(AffinityTopologyVersion topVer,
AffinityTopologyVersion initTopVer,
Throwable err) |
void |
GridCacheProcessor.onExchangeDone(AffinityTopologyVersion cacheStartVer,
ExchangeActions exchActions,
Throwable err)
Callback invoked when first exchange future for dynamic cache is completed.
|
void |
WalStateManager.onGroupRebalanceFinished(int grpId,
AffinityTopologyVersion topVer)
Callback when group rebalancing is finished.
|
void |
CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut,
GridDhtPartitionsFullMessage msg,
AffinityTopologyVersion resTopVer) |
void |
CacheGroupContext.onPartitionCounterUpdate(int cacheId,
int part,
long cntr,
AffinityTopologyVersion topVer,
boolean primary) |
ExchangeActions |
GridCacheProcessor.onStateChangeRequest(ChangeGlobalStateMessage msg,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState curState) |
abstract IgniteInternalFuture<T> |
GridCacheAdapter.AsyncOp.op(GridNearTxLocal tx,
AffinityTopologyVersion readyTopVer) |
boolean |
GridCacheAffinityManager.partitionBelongs(ClusterNode node,
int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.partitionLocalNode(int part,
AffinityTopologyVersion topVer) |
IgniteInternalFuture<?> |
GridCacheSharedContext.partitionReleaseFuture(AffinityTopologyVersion topVer)
Captures all ongoing operations that we need to wait before we can proceed to the next topology version.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
boolean |
GridCacheAffinityManager.primaryByKey(ClusterNode n,
Object key,
AffinityTopologyVersion topVer) |
ClusterNode |
GridCacheAffinityManager.primaryByKey(Object key,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primaryByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
ClusterNode |
GridCacheAffinityManager.primaryByPartition(int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primaryChanged(int part,
AffinityTopologyVersion startVer,
AffinityTopologyVersion endVer) |
Set<Integer> |
GridCacheAffinityManager.primaryPartitions(UUID nodeId,
AffinityTopologyVersion topVer) |
protected GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheConcurrentMap.CacheMapHolder hld,
GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
IgniteRebalanceIterator |
IgniteCacheOffheapManager.rebalanceIterator(IgniteDhtDemandedPartitionsMap parts,
AffinityTopologyVersion topVer) |
IgniteRebalanceIterator |
IgniteCacheOffheapManagerImpl.rebalanceIterator(IgniteDhtDemandedPartitionsMap parts,
AffinityTopologyVersion topVer) |
boolean |
GridCachePreloader.rebalanceRequired(AffinityTopologyVersion rebTopVer,
GridDhtPartitionsExchangeFuture exchFut) |
boolean |
GridCachePreloaderAdapter.rebalanceRequired(AffinityTopologyVersion rebTopVer,
GridDhtPartitionsExchangeFuture exchFut) |
protected void |
GridCacheMapEntry.recordNodeId(UUID nodeId,
AffinityTopologyVersion topVer) |
void |
GridCacheContext.releaseForFastLocalGet(int part,
AffinityTopologyVersion topVer)
Releases the partition that was reserved by a call to
GridCacheContext.reserveForFastLocalGet(int, AffinityTopologyVersion). |
void |
GridCacheMvccManager.removeExplicitNodeLocks(UUID leftNodeId,
AffinityTopologyVersion topVer) |
GridDhtFuture<Object> |
GridCachePreloader.request(GridCacheContext cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloader.request(GridCacheContext cctx,
GridNearAtomicAbstractUpdateRequest req,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
GridNearAtomicAbstractUpdateRequest req,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridCloseableIterator<CacheDataRow> |
IgniteCacheOffheapManager.reservedIterator(int part,
AffinityTopologyVersion topVer) |
GridCloseableIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.reservedIterator(int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheContext.reserveForFastLocalGet(int part,
AffinityTopologyVersion topVer)
Checks if local reads are allowed for the given partition and reserves the partition when needed.
|
IgniteInternalFuture<?> |
GridCacheProcessor.startCachesOnLocalJoin(AffinityTopologyVersion exchTopVer,
LocalJoinCachesContext locJoinCtx) |
Collection<DynamicCacheDescriptor> |
GridCacheProcessor.startReceivedCaches(UUID nodeId,
AffinityTopologyVersion exchTopVer)
Starts statically configured caches received from remote nodes during exchange.
|
void |
DynamicCacheDescriptor.startTopologyVersion(AffinityTopologyVersion startTopVer) |
void |
GridCacheMvccCandidate.topologyVersion(AffinityTopologyVersion topVer) |
void |
GridCacheEntryEx.touch(AffinityTopologyVersion topVer)
Touch this entry in its context's eviction manager.
|
void |
GridCacheMapEntry.touch(AffinityTopologyVersion topVer)
Touch this entry in its context's eviction manager.
|
void |
CacheEvictionManager.touch(GridCacheEntryEx e,
AffinityTopologyVersion topVer) |
void |
GridCacheEvictionManager.touch(GridCacheEntryEx e,
AffinityTopologyVersion topVer) |
void |
CacheOffheapEvictionManager.touch(GridCacheEntryEx e,
AffinityTopologyVersion topVer) |
Map<IgniteTxKey,Collection<GridCacheMvccCandidate>> |
GridCacheMvccManager.unfinishedLocks(AffinityTopologyVersion topVer) |
boolean |
GridCacheEntryEx.valid(AffinityTopologyVersion topVer) |
boolean |
GridCacheMapEntry.valid(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
MetadataUpdateAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
MetadataUpdateProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridDistributedTxFinishRequest.topologyVersion() |
AffinityTopologyVersion |
GridCacheTtlUpdateRequest.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridDistributedCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
| Constructor and Description |
|---|
GridCacheTtlUpdateRequest(int cacheId,
AffinityTopologyVersion topVer,
long ttl) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
AffinityTopologyVersion topVer,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridDhtCacheAdapter.beginMultiUpdate()
Starts multi-update lock.
|
AffinityTopologyVersion |
ClientCacheDhtTopologyFuture.initialVersion()
Returns topology version when exchange started.
|
AffinityTopologyVersion |
GridDhtTopologyFuture.initialVersion()
Returns topology version when exchange started.
|
AffinityTopologyVersion |
ClientCacheDhtTopologyFuture.topologyVersion()
Gets result topology version of this future.
|
AffinityTopologyVersion |
GridDhtTxQueryFirstEnlistRequest.topologyVersion()
Gets topology version or -1 in case of topology version is not required for this message.
|
AffinityTopologyVersion |
GridDhtAffinityAssignmentResponse.topologyVersion() |
AffinityTopologyVersion |
GridDhtUnreservedPartitionException.topologyVersion() |
AffinityTopologyVersion |
GridDhtAffinityAssignmentRequest.topologyVersion() |
AffinityTopologyVersion |
GridDhtTopologyFuture.topologyVersion()
Gets result topology version of this future.
|
AffinityTopologyVersion |
GridDhtTxPrepareRequest.topologyVersion() |
AffinityTopologyVersion |
GridDhtLockRequest.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridDhtTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
protected abstract IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
IgniteInternalFuture<Boolean> |
GridDhtCacheEntry.addReader(UUID nodeId,
long msgId,
AffinityTopologyVersion topVer) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridDhtCacheEntry |
GridDhtCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridDhtFuture<Collection<GridCacheEntryInfo>> |
GridDhtCacheAdapter.getDhtAsync(UUID reader,
long msgId,
Map<KeyCacheObject,Boolean> keys,
boolean addReaders,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean recovery,
MvccSnapshot mvccSnapshot) |
void |
GridPartitionedGetFuture.init(AffinityTopologyVersion topVer)
Initializes future.
|
GridDhtTxLocal |
GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId,
ClusterNode nearNode,
GridCacheVersion nearLockVer,
IgniteUuid nearFutId,
int nearMiniId,
boolean firstClientReq,
AffinityTopologyVersion topVer,
long nearThreadId,
long timeout,
UUID txSubjectId,
int txTaskNameHash) |
IgniteInternalFuture<?> |
GridDhtCacheAdapter.multiUpdateFinishFuture(AffinityTopologyVersion topVer)
Creates multi update finish future.
|
protected boolean |
GridDhtCacheAdapter.needRemap(AffinityTopologyVersion expVer,
AffinityTopologyVersion curVer) |
protected long |
GridDhtCacheEntry.nextPartitionCounter(AffinityTopologyVersion topVer,
boolean primary,
Long primaryCntr) |
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
protected ClusterTopologyServerNotFoundException |
CacheDistributedGetFutureAdapter.serverNotFoundError(AffinityTopologyVersion topVer) |
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer) |
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer,
IgniteCheckedException e) |
GridDhtAffinityAssignmentRequest(long futId,
int grpId,
AffinityTopologyVersion topVer,
boolean sndPartMap) |
GridDhtAffinityAssignmentResponse(long futId,
int grpId,
AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment) |
GridDhtAssignmentFetchFuture(GridCacheSharedContext ctx,
int grpId,
AffinityTopologyVersion topVer,
DiscoCache discoCache) |
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
boolean addReaders,
MvccSnapshot mvccSnapshot) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
boolean addRdr,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnVal,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
AffinityTopologyVersion topVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean storeUsed,
boolean keepBinary,
boolean addDepInfo) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
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) |
GridDhtTxPrepareRequest(IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
long timeout,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> counters) |
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,
UUID subjId,
int taskNameHash,
boolean single,
boolean storeWriteThrough)
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,
UUID subjId,
int taskNameHash,
boolean storeWriteThrough)
This constructor is meant for pessimistic transactions.
|
GridDhtUnreservedPartitionException(int part,
AffinityTopologyVersion topVer,
String msg) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
MvccSnapshot mvccSnapshot) |
| Modifier and Type | Field and Description |
|---|---|
protected AffinityTopologyVersion |
GridNearAtomicAbstractUpdateFuture.remapTopVer |
protected AffinityTopologyVersion |
GridNearAtomicAbstractUpdateRequest.topVer
Topology version.
|
protected AffinityTopologyVersion |
GridDhtAtomicAbstractUpdateRequest.topVer
Topology version.
|
protected AffinityTopologyVersion |
GridNearAtomicAbstractUpdateFuture.topVer
Current topology version.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridNearAtomicAbstractUpdateRequest.topologyVersion()
Gets topology version or -1 in case of topology version is not required for this message.
|
AffinityTopologyVersion |
GridDhtAtomicAbstractUpdateRequest.topologyVersion()
Gets topology version or -1 in case of topology version is not required for this message.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Void> |
GridNearAtomicAbstractUpdateFuture.completeFuture(AffinityTopologyVersion topVer)
Gets future that will be completed when it is safe when update is finished on the given version of topology.
|
IgniteInternalFuture<Void> |
GridDhtAtomicAbstractUpdateFuture.completeFuture(AffinityTopologyVersion topVer)
Gets future that will be completed when it is safe when update is finished on the given version of topology.
|
protected abstract GridDhtAtomicAbstractUpdateRequest |
GridDhtAtomicAbstractUpdateFuture.createRequest(UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
protected void |
GridNearAtomicSingleUpdateFuture.map(AffinityTopologyVersion topVer) |
protected abstract void |
GridNearAtomicAbstractUpdateFuture.map(AffinityTopologyVersion topVer) |
protected void |
GridNearAtomicUpdateFuture.map(AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridDhtAtomicAbstractUpdateRequest(int cacheId,
UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore)
Constructor.
|
GridDhtAtomicUpdateRequest(int cacheId,
UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
Object[] invokeArgs,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore,
boolean forceTransformBackups)
Constructor.
|
GridNearAtomicAbstractSingleUpdateRequest(int cacheId,
UUID nodeId,
long futId,
AffinityTopologyVersion topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
UUID subjId,
int taskNameHash,
byte flags,
boolean addDepInfo)
Constructor.
|
GridNearAtomicAbstractUpdateRequest(int cacheId,
UUID nodeId,
long futId,
AffinityTopologyVersion topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
UUID subjId,
int taskNameHash,
byte flags,
boolean addDepInfo)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridDistributedCacheEntry |
GridDhtColocatedCache.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean allowDetached)
Gets or creates entry for given key and given topology version.
|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
MvccSnapshot mvccSnapshot) |
IgniteInternalFuture<Object> |
GridDhtColocatedCache.loadAsync(KeyCacheObject key,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
boolean recovery,
MvccSnapshot mvccSnapshot) |
| Modifier and Type | Field and Description |
|---|---|
protected AffinityTopologyVersion |
GridDhtPartitionMap.top
Topology version.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridDhtPartitionsExchangeFuture.initialVersion()
Gets the affinity topology version for which this exchange was created.
|
AffinityTopologyVersion |
GridDhtPartitionsFullMessage.resultTopologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionDemander.RebalanceFuture.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionMap.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionExchangeId.topologyVersion() |
AffinityTopologyVersion |
GridDhtForceKeysRequest.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionsExchangeFuture.topologyVersion()
Gets result topology version of this future.
|
AffinityTopologyVersion |
GridDhtPartitionDemandLegacyMessage.topologyVersion() |
AffinityTopologyVersion |
GridDhtPreloaderAssignments.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionDemandMessage.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionsFullMessage.topologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionSupplyMessage.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
LatchAckMessage.topVer() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ExchangeLatchManager.canSkipJoiningNodes(AffinityTopologyVersion topVer)
Checks that latch manager can use V2 protocol and skip joining nodes from latch participants.
|
Latch |
ExchangeLatchManager.getOrCreate(String id,
AffinityTopologyVersion topVer)
Creates new latch with specified
id and topVer or returns existing latch. |
| Constructor and Description |
|---|
LatchAckMessage(String latchId,
AffinityTopologyVersion topVer,
boolean isFinal)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridClientPartitionTopology.lastTopologyChangeVersion() |
AffinityTopologyVersion |
GridDhtPartitionTopology.lastTopologyChangeVersion() |
AffinityTopologyVersion |
GridDhtPartitionTopologyImpl.lastTopologyChangeVersion() |
AffinityTopologyVersion |
GridClientPartitionTopology.readyTopologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionTopology.readyTopologyVersion() |
AffinityTopologyVersion |
GridDhtPartitionTopologyImpl.readyTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridClientPartitionTopology.afterStateRestored(AffinityTopologyVersion topVer)
Initializes local data structures after partitions are restored from persistence.
|
void |
GridDhtPartitionTopology.afterStateRestored(AffinityTopologyVersion topVer)
Initializes local data structures after partitions are restored from persistence.
|
void |
GridDhtPartitionTopologyImpl.afterStateRestored(AffinityTopologyVersion topVer)
Initializes local data structures after partitions are restored from persistence.
|
boolean |
GridDhtLocalPartition.backup(AffinityTopologyVersion topVer) |
boolean |
GridClientPartitionTopology.detectLostPartitions(AffinityTopologyVersion affVer,
DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
boolean |
GridDhtPartitionTopology.detectLostPartitions(AffinityTopologyVersion resTopVer,
DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
boolean |
GridDhtPartitionTopologyImpl.detectLostPartitions(AffinityTopologyVersion resTopVer,
DiscoveryEvent discoEvt)
Checks if there is at least one owner for each partition in the cache topology.
|
boolean |
GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer,
GridDhtPartitionsExchangeFuture exchFut) |
boolean |
GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer,
GridDhtPartitionsExchangeFuture exchFut) |
boolean |
GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer,
GridDhtPartitionsExchangeFuture exchFut) |
GridDhtLocalPartition |
GridClientPartitionTopology.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create) |
GridDhtLocalPartition |
GridDhtPartitionTopology.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create) |
GridDhtLocalPartition |
GridDhtPartitionTopologyImpl.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create) |
GridDhtLocalPartition |
GridClientPartitionTopology.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create,
boolean showRenting) |
GridDhtLocalPartition |
GridDhtPartitionTopology.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create,
boolean showRenting) |
GridDhtLocalPartition |
GridDhtPartitionTopologyImpl.localPartition(int p,
AffinityTopologyVersion topVer,
boolean create,
boolean showRenting) |
long |
GridDhtLocalPartition.nextUpdateCounter(int cacheId,
AffinityTopologyVersion topVer,
boolean primary,
Long primaryCntr) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.owners(int p,
AffinityTopologyVersion topVer) |
void |
GridClientPartitionTopology.ownMoving(AffinityTopologyVersion topVer)
Owns all moving partitions for the given topology version.
|
void |
GridDhtPartitionTopology.ownMoving(AffinityTopologyVersion topVer)
Owns all moving partitions for the given topology version.
|
void |
GridDhtPartitionTopologyImpl.ownMoving(AffinityTopologyVersion topVer)
Owns all moving partitions for the given topology version.
|
boolean |
GridDhtLocalPartition.primary(AffinityTopologyVersion topVer) |
boolean |
GridClientPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer) |
boolean |
GridDhtPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer) |
boolean |
GridDhtPartitionTopologyImpl.rebalanceFinished(AffinityTopologyVersion topVer) |
void |
GridClientPartitionTopology.resetLostPartitions(AffinityTopologyVersion affVer)
Resets the state of all LOST partitions to OWNING.
|
void |
GridDhtPartitionTopology.resetLostPartitions(AffinityTopologyVersion resTopVer)
Resets the state of all LOST partitions to OWNING.
|
void |
GridDhtPartitionTopologyImpl.resetLostPartitions(AffinityTopologyVersion resTopVer)
Resets the state of all LOST partitions to OWNING.
|
boolean |
GridClientPartitionTopology.update(AffinityTopologyVersion exchangeVer,
GridDhtPartitionFullMap partMap,
CachePartitionFullCountersMap cntrMap,
Set<Integer> partsToReload,
Map<Integer,Long> partSizes,
AffinityTopologyVersion msgTopVer) |
boolean |
GridDhtPartitionTopology.update(AffinityTopologyVersion exchangeResVer,
GridDhtPartitionFullMap partMap,
CachePartitionFullCountersMap cntrMap,
Set<Integer> partsToReload,
Map<Integer,Long> partSizes,
AffinityTopologyVersion msgTopVer) |
boolean |
GridDhtPartitionTopologyImpl.update(AffinityTopologyVersion exchangeVer,
GridDhtPartitionFullMap partMap,
CachePartitionFullCountersMap incomeCntrMap,
Set<Integer> partsToReload,
Map<Integer,Long> partSizes,
AffinityTopologyVersion msgTopVer) |
| Constructor and Description |
|---|
GridDhtPartitionsReservation(AffinityTopologyVersion topVer,
GridCacheContext<?,?> cctx,
Object appKey) |
| Modifier and Type | Field and Description |
|---|---|
protected AffinityTopologyVersion |
GridNearTxAbstractEnlistFuture.topVer |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridNearLockResponse.clientRemapVersion() |
AffinityTopologyVersion |
GridNearLockRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearTxQueryResultsEnlistRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearSingleGetResponse.topologyVersion() |
AffinityTopologyVersion |
GridNearTxEnlistRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearGetResponse.topologyVersion() |
AffinityTopologyVersion |
GridNearTxQueryEnlistRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearGetRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearTxPrepareRequest.topologyVersion() |
AffinityTopologyVersion |
GridNearSingleGetRequest.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridNearCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
protected IgniteInternalFuture<Boolean> |
GridNearTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
GridCacheMapEntry |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridNearCacheEntry |
GridNearCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e,
GridCacheVersion obsoleteVer,
AffinityTopologyVersion topVer) |
<K,V> IgniteInternalFuture<Map<K,V>> |
GridNearTxLocal.getAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
boolean needVer) |
void |
GridNearGetFuture.init(AffinityTopologyVersion topVer)
Initializes future.
|
void |
GridNearTxSelectForUpdateFuture.init(AffinityTopologyVersion topVer,
Collection<ClusterNode> nodes)
Initialize this future for distributed execution.
|
void |
GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer) |
void |
GridNearGetResponse.invalidPartitions(Collection<Integer> invalidParts,
AffinityTopologyVersion topVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor,
Object... invokeArgs) |
<K,V,T> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map,
Object... invokeArgs) |
protected boolean |
GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e,
AffinityTopologyVersion topVer) |
boolean |
GridNearCacheEntry.loadedValue(IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
long ttl,
long expireTime,
boolean evt,
boolean keepBinary,
AffinityTopologyVersion topVer,
UUID subjId) |
void |
GridNearTxLocal.onRemap(AffinityTopologyVersion topVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.putAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Map<? extends K,? extends V> map,
boolean retval) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
protected void |
GridNearCacheEntry.recordNodeId(UUID primaryNodeId,
AffinityTopologyVersion topVer) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
GridNearTxLocal.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
boolean |
GridNearCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
void |
GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer,
CacheObject val,
long expireTime,
long ttl,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
boolean |
GridNearCacheEntry.valid(AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridNearLockRequest(int cacheId,
AffinityTopologyVersion topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
boolean retVal,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean firstClientReq,
boolean nearCache,
boolean addDepInfo) |
GridNearLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int miniId,
boolean filterRes,
int cnt,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean addDepInfo) |
GridNearSingleGetRequest(int cacheId,
long futId,
KeyCacheObject key,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipVals,
boolean addReader,
boolean needVer,
boolean addDepInfo,
boolean recovery,
MvccSnapshot mvccSnapshot) |
GridNearSingleGetResponse(int cacheId,
long futId,
AffinityTopologyVersion topVer,
Message res,
boolean invalidPartitions,
boolean addDepInfo) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
GridNearTxLocal tx,
long timeout,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean allowWaitTopFut,
boolean addDepInfo) |
GridNearTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
GridCacheVersion dhtVer,
GridCacheVersion writeVer,
GridCacheReturn retVal,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean onePhaseCommit,
boolean addDepInfo) |
GridNearTxQueryEnlistRequest(int cacheId,
long threadId,
IgniteUuid futId,
int miniId,
UUID subjId,
AffinityTopologyVersion topVer,
GridCacheVersion lockVer,
MvccSnapshot mvccSnapshot,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
long txTimeout,
int taskNameHash,
boolean clientFirst) |
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.onExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions exchange event.
|
void |
GridCacheDrManager.onExchange(AffinityTopologyVersion topVer,
boolean left)
Process partitions exchange event.
|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
MvccTxEntry.topologyVersion() |
AffinityTopologyVersion |
MvccQueryTracker.topologyVersion() |
AffinityTopologyVersion |
MvccCoordinator.topologyVersion() |
AffinityTopologyVersion |
StaticMvccQueryTracker.topologyVersion() |
AffinityTopologyVersion |
MvccQueryTrackerImpl.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
MvccCoordinator |
MvccProcessorImpl.currentCoordinator(AffinityTopologyVersion topVer)
Check that the given topology is greater or equals to coordinator's one and returns current coordinator.
|
MvccCoordinator |
MvccProcessor.currentCoordinator(AffinityTopologyVersion topVer)
Check that the given topology is greater or equals to coordinator's one and returns current coordinator.
|
static ClusterTopologyServerNotFoundException |
MvccUtils.noCoordinatorError(AffinityTopologyVersion topVer) |
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
StaticMvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
IgniteInternalFuture<MvccSnapshot> |
MvccQueryTrackerImpl.requestSnapshot(AffinityTopologyVersion topVer)
Requests version on coordinator.
|
void |
MvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer,
MvccSnapshotResponseListener lsnr)
Requests version on coordinator.
|
void |
StaticMvccQueryTracker.requestSnapshot(AffinityTopologyVersion topVer,
MvccSnapshotResponseListener lsnr)
Requests version on coordinator.
|
void |
MvccQueryTrackerImpl.requestSnapshot(AffinityTopologyVersion topVer,
MvccSnapshotResponseListener lsnr)
Requests version on coordinator.
|
| Constructor and Description |
|---|
MvccCoordinator(UUID nodeId,
long crdVer,
AffinityTopologyVersion topVer) |
MvccTxEntry(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture |
IgniteCacheSnapshotManager.startLocalSnapshotOperation(UUID initiatorNodeId,
T snapshotOperation,
AffinityTopologyVersion topVer) |
IgniteInternalFuture |
IgniteCacheSnapshotManager.tryStartLocalSnapshotOperation(DiscoveryEvent discoveryEvent,
AffinityTopologyVersion topVer)
Try to start local snapshot operation if it's required by discovery event.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridCacheQueryManager.queryTopologyVersion() |
AffinityTopologyVersion |
GridCacheQueryRequest.topologyVersion()
Gets topology version or -1 in case of topology version is not required for this message.
|
| Constructor and Description |
|---|
GridCacheQueryRequest(int cacheId,
long id,
boolean fields,
AffinityTopologyVersion topVer,
boolean addDepInfo)
Creates cancel query request.
|
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
int pageSize,
boolean incBackups,
boolean fields,
boolean all,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
boolean addDepInfo)
Request to load page.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryManager.flushBackupQueue(AffinityTopologyVersion topVer) |
void |
CacheContinuousQueryListener.flushBackupQueue(GridKernalContext ctx,
AffinityTopologyVersion topVer)
Flushes backup queue.
|
void |
CacheContinuousQueryManager.onEntryUpdated(KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
void |
CacheContinuousQueryManager.onEntryUpdated(Map<UUID,CacheContinuousQueryListener> lsnrCol,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
CounterSkipContext |
CacheContinuousQueryManager.skipUpdateCounter(CounterSkipContext skipCtx,
int part,
long cntr,
AffinityTopologyVersion topVer,
boolean primary) |
CounterSkipContext |
CacheContinuousQueryListener.skipUpdateCounter(GridCacheContext cctx,
CounterSkipContext skipCtx,
int part,
long cntr,
AffinityTopologyVersion topVer,
boolean primary)
For cache updates in shared cache group need notify others caches CQ listeners
that generated counter should be skipped.
|
void |
CacheContinuousQueryListener.skipUpdateEvent(org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEvent<K,V> evt,
AffinityTopologyVersion topVer,
boolean primary) |
void |
CacheContinuousQueryHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Modifier and Type | Field and Description |
|---|---|
protected AffinityTopologyVersion |
IgniteTxAdapter.topVer
Topology version.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
IgniteTxManager.lockedTopologyVersion(long threadId,
IgniteInternalTx ignore) |
AffinityTopologyVersion |
IgniteTxAdapter.topologyVersion() |
AffinityTopologyVersion |
IgniteInternalTx.topologyVersion() |
AffinityTopologyVersion |
IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer)
Attempts to set topology version and returns the current value.
|
AffinityTopologyVersion |
IgniteInternalTx.topologyVersion(AffinityTopologyVersion topVer)
Attempts to set topology version and returns the current value.
|
AffinityTopologyVersion |
IgniteTxAdapter.topologyVersionSnapshot() |
AffinityTopologyVersion |
IgniteInternalTx.topologyVersionSnapshot() |
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
IgniteInternalFuture<?> |
IgniteTxManager.finishAllTxs(IgniteInternalFuture<?> finishLocalTxsFuture,
AffinityTopologyVersion topVer)
Creates a future that will wait for finishing all tx updates on backups after all local transactions are finished.
|
IgniteInternalFuture<Boolean> |
IgniteTxManager.finishLocalTxs(AffinityTopologyVersion topVer)
Creates a future that will wait for all ongoing transactions that maybe affected by topology update
to be finished.
|
boolean |
IgniteTxManager.needWaitTransaction(IgniteInternalTx tx,
AffinityTopologyVersion topVer) |
void |
IgniteTxManager.rollbackOnTopologyChange(AffinityTopologyVersion topVer)
Rollback transactions blocking partition map exchange.
|
boolean |
IgniteTxManager.setTxTopologyHint(AffinityTopologyVersion topVer) |
AffinityTopologyVersion |
IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer)
Attempts to set topology version and returns the current value.
|
AffinityTopologyVersion |
IgniteInternalTx.topologyVersion(AffinityTopologyVersion topVer)
Attempts to set topology version and returns the current value.
|
protected boolean |
IgniteTxAdapter.updateNearCache(GridCacheContext<?,?> cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
| Modifier and Type | Field and Description |
|---|---|
AffinityTopologyVersion |
CacheInfo.topVer
Topology version.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
CacheInfo.getTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheInfo.setTopologyVersion(AffinityTopologyVersion topologyVersion) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheVersionManager.next(AffinityTopologyVersion topVer)
Gets next version based on given topology version.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad(AffinityTopologyVersion topVer)
Gets next version for cache store load and reload operations.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
AffinityTask.topologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
DiscoveryDataClusterState.transitionTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
ChangeGlobalStateFinishMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
ChangeGlobalStateMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
boolean |
GridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer,
ChangeGlobalStateMessage msg,
DiscoCache discoCache) |
boolean |
IGridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer,
ChangeGlobalStateMessage msg,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
AbstractContinuousMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
void |
GridContinuousHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
DataStreamerRequest.topologyVersion() |
| Constructor and Description |
|---|
DataStreamerRequest(long reqId,
byte[] resTopicBytes,
String cacheName,
byte[] updaterBytes,
Collection<DataStreamerEntry> entries,
boolean ignoreDepOwnership,
boolean skipStore,
boolean keepBinary,
DeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,IgniteUuid> ldrParticipants,
IgniteUuid clsLdrId,
boolean forceLocDep,
AffinityTopologyVersion topVer,
int partId) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
MappingProposedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
DiscoCache |
MappingAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Modifier and Type | Method and Description |
|---|---|
static AffinityTopologyVersion |
GridQueryProcessor.getRequestAffinityTopologyVersion() |
| Modifier and Type | Method and Description |
|---|---|
IndexingQueryFilter |
GridQueryIndexing.backupFilter(AffinityTopologyVersion topVer,
int[] parts)
Returns backup filter.
|
UpdateSourceIterator<?> |
GridQueryIndexing.prepareDistributedUpdate(GridCacheContext<?,?> cctx,
int[] ids,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
UpdateSourceIterator<?> |
GridQueryProcessor.prepareDistributedUpdate(GridCacheContext<?,?> cctx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
int timeout,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
GridQueryCancel cancel) |
static void |
GridQueryProcessor.setRequestAffinityTopologyVersion(AffinityTopologyVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
GridQueryNextPageResponse.retry() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridQueryNextPageResponse.retry(AffinityTopologyVersion retry) |
| Modifier and Type | Method and Description |
|---|---|
DiscoCache |
SchemaAbstractDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.
|
| Constructor and Description |
|---|
VisorAffinityTopologyVersion(AffinityTopologyVersion affTopVer)
Create data transfer object for affinity topology version.
|
| Modifier and Type | Method and Description |
|---|---|
AffinityTopologyVersion |
VisorTxInfo.getTopologyVersion() |
| Constructor and Description |
|---|
VisorTxInfo(IgniteUuid xid,
long startTime,
long duration,
TransactionIsolation isolation,
TransactionConcurrency concurrency,
long timeout,
String lb,
Collection<UUID> primaryNodes,
TransactionState state,
int size,
IgniteUuid nearXid,
Collection<UUID> masterNodeIds,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
IndexingQueryCacheFilter(GridCacheAffinityManager aff,
Set<Integer> parts,
AffinityTopologyVersion topVer,
ClusterNode locNode)
Constructor.
|
IndexingQueryFilterImpl(GridKernalContext ctx,
AffinityTopologyVersion topVer,
int[] partsArr)
Constructor.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019