|
Merge Parameter [id : String, topVer : AffinityTopologyVersion] to latchUid : CompletableLatchUid in method package ClientLatch(latchUid CompletableLatchUid, coordinator ClusterNode, participants Collection<ClusterNode>) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager.ClientLatch |
From |
To |
|
Merge Parameter [id : String, topVer : AffinityTopologyVersion] to latchUid : CompletableLatchUid in method package CompletableLatch(latchUid CompletableLatchUid, participants Collection<ClusterNode>) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager.CompletableLatch |
From |
To |
|
Merge Parameter [id : String, topVer : AffinityTopologyVersion] to latchUid : CompletableLatchUid in method private createServerLatch(latchUid CompletableLatchUid, participants Collection<ClusterNode>) : Latch in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Merge Parameter [id : String, topVer : AffinityTopologyVersion] to latchUid : CompletableLatchUid in method package ServerLatch(latchUid CompletableLatchUid, participants Collection<ClusterNode>) in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager.ServerLatch |
From |
To |
|
Change Variable Type latchesToRestore : List<T2<String,AffinityTopologyVersion>> to latchesToRestore : Set<CompletableLatchUid> in method private becomeNewCoordinator() : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type latchId : T2<String,AffinityTopologyVersion> to latchUid : CompletableLatchUid in method private createServerLatch(latchUid CompletableLatchUid, participants Collection<ClusterNode>) : Latch in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type latchId : T2<String,AffinityTopologyVersion> to latchUid : CompletableLatchUid in method private becomeNewCoordinator() : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type latchEntry : Map.Entry<T2<String,AffinityTopologyVersion>,ServerLatch> to latchEntry : Map.Entry<CompletableLatchUid,ServerLatch> in method private processNodeLeft(left ClusterNode) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type latchEntry : Map.Entry<T2<String,AffinityTopologyVersion>,ClientLatch> to latchEntry : Map.Entry<CompletableLatchUid,ClientLatch> in method private processNodeLeft(left ClusterNode) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type latchId : T2<String,AffinityTopologyVersion> to latchUid : CompletableLatchUid in method private processAck(from UUID, message LatchAckMessage) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Variable Type ackEntry : Map.Entry<T2<String,AffinityTopologyVersion>,Set<UUID>> to ackEntry : Map.Entry<CompletableLatchUid,Set<UUID>> in method private processNodeLeft(left ClusterNode) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Attribute Type clientLatches : ConcurrentMap<T2<String,AffinityTopologyVersion>,ClientLatch> to clientLatches : ConcurrentMap<CompletableLatchUid,ClientLatch> in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Attribute Type serverLatches : ConcurrentMap<T2<String,AffinityTopologyVersion>,ServerLatch> to serverLatches : ConcurrentMap<CompletableLatchUid,ServerLatch> in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |
|
Change Attribute Type pendingAcks : ConcurrentMap<T2<String,AffinityTopologyVersion>,Set<UUID>> to pendingAcks : ConcurrentMap<CompletableLatchUid,Set<UUID>> in class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager |
From |
To |