|
Change Parameter Type cnt : int to rebalanceId : long in method public addAssignments(assignments GridDhtPreloaderAssignments, forceRebalance boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader |
From |
To |
|
Change Parameter Type cnt : int to rebalanceId : long in method package addAssignments(assignments GridDhtPreloaderAssignments, force boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Change Parameter Type cp : GridDhtPartitionDemandMessage to cp : GridDhtPartitionDemandLegacyMessage in method package GridDhtPartitionDemandLegacyMessage(cp GridDhtPartitionDemandLegacyMessage, parts Collection<Integer>, partsCntrs Map<Integer,Long>) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Change Parameter Type cnt : int to rebalanceId : long in method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Move Attribute private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage to private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Move Attribute private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage to private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Move Attribute private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture to private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Move Attribute private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier.SupplyContext to private updateSeq : long from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Move Attribute private partsCntrs : Map<Integer,Long> from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage to private partsCntrs : Map<Integer,Long> from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Move Attribute private historicalParts : Collection<Integer> from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage to private historicalParts : Collection<Integer> from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage |
From |
To |
|
Change Variable Type parts : Collection<Integer> to parts : IgniteDhtDemandedPartitionsMap in method private partitionDone(nodeId UUID, p int) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture |
From |
To |
|
Change Variable Type partIt : Iterator<Integer> to histMap : CachePartitionPartialCountersMap in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Change Variable Type parts : Collection<Integer> to parts : IgniteDhtDemandedPartitionsMap in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Change Variable Type cnt : int to cnt : long in method protected body() : void in class org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.ExchangeWorker |
From |
To |
|
Change Variable Type t : T2<Long,Collection<Integer>> to t : T2<Long,IgniteDhtDemandedPartitionsMap> in method private partitionDone(nodeId UUID, p int) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture |
From |
To |
|
Change Variable Type cctx : GridCacheContext<Object,Object> to grp : CacheGroupContext in method public testHistoricalRebalanceIterator() : void in class org.apache.ignite.internal.processors.cache.persistence.db.wal.WalRecoveryTxLogicalRecordsTest |
From |
To |
|
Change Variable Type sParts : List<Set<Integer>> to stripePartitions : List<IgniteDhtDemandedPartitionsMap> in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Change Variable Type it : Iterator to it : IgniteRebalanceIterator in method private clearContext(sc SupplyContext, log IgniteLogger) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Method public assign(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments renamed to public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloaderAdapter |
From |
To |
|
Rename Method public tryEvictAsync(updateSeq boolean) : void renamed to private finishEviction(updateSeq boolean) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition |
From |
To |
|
Rename Method public assign(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments renamed to public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Rename Method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, cnt int, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable renamed to public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Rename Method public assign(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments renamed to public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Rename Method package updateSequence() : long renamed to package rebalanceId() : long in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage |
From |
To |
|
Rename Method private pickedOwners(p int, topVer AffinityTopologyVersion) : Collection<ClusterNode> renamed to private pickOwners(p int, topVer AffinityTopologyVersion) : Collection<ClusterNode> in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader |
From |
To |
|
Rename Method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, cnt int, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable renamed to public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.GridCachePreloaderAdapter |
From |
To |
|
Rename Method public testRebalanceIterator() : void renamed to public testHistoricalRebalanceIterator() : void in class org.apache.ignite.internal.processors.cache.persistence.db.wal.WalRecoveryTxLogicalRecordsTest |
From |
To |
|
Rename Method package updateSequence(updateSeq long) : void renamed to package rebalanceId(updateSeq long) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage |
From |
To |
|
Rename Method public assign(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments renamed to public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader |
From |
To |
|
Rename Method package updateSequence() : long renamed to package rebalanceId() : long in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage |
From |
To |
|
Rename Variable state : long to state0 : long in method private finishEviction(updateSeq boolean) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition |
From |
To |
|
Rename Variable cutTop : AffinityTopologyVersion to curTop : AffinityTopologyVersion in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Variable lsnrCnt : int to stripes : int in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Variable assigns : GridDhtPreloaderAssignments to assignments : GridDhtPreloaderAssignments in method public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader |
From |
To |
|
Rename Variable finalCnt : int to topicId : int in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Variable partIt : Iterator<Integer> to histMap : CachePartitionPartialCountersMap in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Variable initD : GridDhtPartitionDemandMessage to demandMsg : GridDhtPartitionDemandMessage in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Variable sParts : List<Set<Integer>> to stripePartitions : List<IgniteDhtDemandedPartitionsMap> in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Variable bCnt : long to batchesCnt : long in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Variable cctx : GridCacheContext<Object,Object> to grp : CacheGroupContext in method public testHistoricalRebalanceIterator() : void in class org.apache.ignite.internal.processors.cache.persistence.db.wal.WalRecoveryTxLogicalRecordsTest |
From |
To |
|
Change Return Type void to long in method private clearAll() : long in class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition |
From |
To |
|
Change Return Type void to boolean in method private clearEvicting() : boolean in class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition |
From |
To |
|
Change Return Type GridDhtPreloaderAssignments to Runnable in method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloaderAdapter |
From |
To |
|
Change Return Type Runnable to GridDhtPreloaderAssignments in method public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.GridCachePreloaderAdapter |
From |
To |
|
Change Return Type Collection<Integer> to IgniteDhtDemandedPartitionsMap in method package partitions() : IgniteDhtDemandedPartitionsMap in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage |
From |
To |
|
Change Return Type Runnable to GridDhtPreloaderAssignments in method public generateAssignments(exchId GridDhtPartitionExchangeId, exchFut GridDhtPartitionsExchangeFuture) : GridDhtPreloaderAssignments in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Change Return Type GridDhtPreloaderAssignments to Runnable in method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Rename Parameter updateSeq : long to rebalanceId : long in method private isActual(rebalanceId long) : boolean in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture |
From |
To |
|
Rename Parameter idx : int to topicId : int in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Parameter assigns : GridDhtPreloaderAssignments to assignments : GridDhtPreloaderAssignments in method package addAssignments(assignments GridDhtPreloaderAssignments, force boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Parameter cnt : int to rebalanceId : long in method package addAssignments(assignments GridDhtPreloaderAssignments, force boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Parameter updateSeq : long to rebalanceId : long in method package RebalanceFuture(grp CacheGroupContext, assignments GridDhtPreloaderAssignments, log IgniteLogger, rebalanceId long) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture |
From |
To |
|
Rename Parameter n : ClusterNode to node : ClusterNode in method private reply(node ClusterNode, d GridDhtPartitionDemandMessage, s GridDhtPartitionSupplyMessage, contextId T3<UUID,Integer,AffinityTopologyVersion>) : boolean in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Parameter cnt : int to rebalanceId : long in method public addAssignments(assignments GridDhtPreloaderAssignments, forceRebalance boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader |
From |
To |
|
Rename Parameter pick : ClusterNode to from : ClusterNode in method private preloadEntry(from ClusterNode, p int, entry GridCacheEntryInfo, topVer AffinityTopologyVersion) : boolean in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Parameter updateSeq : long to rebalanceId : long in method package GridDhtPartitionSupplyMessage(rebalanceId long, grpId int, topVer AffinityTopologyVersion, addDepInfo boolean) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage |
From |
To |
|
Rename Parameter assigns : GridDhtPreloaderAssignments to assignments : GridDhtPreloaderAssignments in method package RebalanceFuture(grp CacheGroupContext, assignments GridDhtPreloaderAssignments, log IgniteLogger, rebalanceId long) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture |
From |
To |
|
Rename Parameter id : UUID to nodeId : UUID in method public handleDemandMessage(topicId int, nodeId UUID, d GridDhtPartitionDemandMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Parameter assigns : GridDhtPreloaderAssignments to assignments : GridDhtPreloaderAssignments in method private requestPartitions(fut RebalanceFuture, assignments GridDhtPreloaderAssignments) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Parameter cnt : int to rebalanceId : long in method public addAssignments(assignments GridDhtPreloaderAssignments, forcePreload boolean, rebalanceId long, next Runnable, forcedRebFut GridCompoundFuture<Boolean,Boolean>) : Runnable in class org.apache.ignite.internal.processors.cache.GridCachePreloader |
From |
To |
|
Rename Parameter scId : T3<UUID,Integer,AffinityTopologyVersion> to contextId : T3<UUID,Integer,AffinityTopologyVersion> in method private reply(node ClusterNode, d GridDhtPartitionDemandMessage, s GridDhtPartitionSupplyMessage, contextId T3<UUID,Integer,AffinityTopologyVersion>) : boolean in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplier |
From |
To |
|
Rename Parameter updateSeq : long to rebalanceId : long in method package GridDhtPartitionDemandMessage(rebalanceId long, topVer AffinityTopologyVersion, grpId int) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage |
From |
To |
|
Rename Parameter id : UUID to nodeId : UUID in method public handleSupplyMessage(topicId int, nodeId UUID, supply GridDhtPartitionSupplyMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |
|
Rename Parameter idx : int to topicId : int in method public handleSupplyMessage(topicId int, nodeId UUID, supply GridDhtPartitionSupplyMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander |
From |
To |