Skip to content

Commit a08bbfd

Browse files
authored
IGNITE-24094 Remove GridDhtPartitionDemandMessage#VERSION_SINCE (#11813)
1 parent acf8b16 commit a08bbfd

File tree

6 files changed

+3
-498
lines changed

6 files changed

+3
-498
lines changed

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,6 @@
9191
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.CacheGroupAffinityMessage;
9292
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtForceKeysRequest;
9393
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtForceKeysResponse;
94-
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage;
9594
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage;
9695
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionExchangeId;
9796
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage;
@@ -241,7 +240,6 @@ public class GridIoMessageFactory implements MessageFactoryProvider {
241240
factory.register((short)41, GridNearAtomicUpdateResponse::new);
242241
factory.register((short)42, GridDhtForceKeysRequest::new);
243242
factory.register((short)43, GridDhtForceKeysResponse::new);
244-
factory.register((short)44, GridDhtPartitionDemandLegacyMessage::new);
245243
factory.register((short)45, GridDhtPartitionDemandMessage::new);
246244
factory.register((short)46, GridDhtPartitionsFullMessage::new);
247245
factory.register((short)47, GridDhtPartitionsSingleMessage::new);

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,6 @@
8989
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.CachePartitionPartialCountersMap;
9090
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.FinishPreloadingTask;
9191
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.ForceRebalanceExchangeTask;
92-
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage;
9392
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage;
9493
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture;
9594
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionExchangeId;
@@ -494,12 +493,6 @@ else if (m instanceof GridDhtPartitionDemandMessage) {
494493

495494
return;
496495
}
497-
else if (m instanceof GridDhtPartitionDemandLegacyMessage) {
498-
grp.preloader().handleDemandMessage(idx, id,
499-
new GridDhtPartitionDemandMessage((GridDhtPartitionDemandLegacyMessage)m));
500-
501-
return;
502-
}
503496
else
504497
U.error(log, "Unsupported message type: " + m.getClass().getName());
505498
}

0 commit comments

Comments
 (0)