IGNITE-15282 Remove unused the private clear method in GridDhtLocalPartition (#9316)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtLocalPartition.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtLocalPartition.java
index 46a1fbe..da0383f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtLocalPartition.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtLocalPartition.java
@@ -1082,65 +1082,6 @@
}
/**
- * Removes all cache entries from specified {@code map}.
- *
- * @param map Map to clear.
- * @param extras Obsolete extras.
- * @param evt Unload event flag.
- * @throws NodeStoppingException If current node is stopping.
- */
- private void clear(ConcurrentMap<KeyCacheObject, GridCacheMapEntry> map,
- GridCacheObsoleteEntryExtras extras,
- boolean evt) throws NodeStoppingException {
- Iterator<GridCacheMapEntry> it = map.values().iterator();
-
- while (it.hasNext()) {
- GridCacheMapEntry cached = null;
-
- ctx.database().checkpointReadLock();
-
- try {
- cached = it.next();
-
- if (cached instanceof GridDhtCacheEntry && ((GridDhtCacheEntry)cached).clearInternal(extras.obsoleteVersion(), extras)) {
- removeEntry(cached);
-
- if (!cached.isInternal()) {
- if (evt) {
- grp.addCacheEvent(cached.partition(),
- cached.key(),
- ctx.localNodeId(),
- EVT_CACHE_REBALANCE_OBJECT_UNLOADED,
- null,
- false,
- cached.rawGet(),
- cached.hasValue(),
- false);
- }
- }
- }
- }
- catch (GridDhtInvalidPartitionException e) {
- assert isEmpty() && state() == EVICTED : "Invalid error [e=" + e + ", part=" + this + ']';
-
- break; // Partition is already concurrently cleared and evicted.
- }
- catch (NodeStoppingException e) {
- if (log.isDebugEnabled())
- log.debug("Failed to clear cache entry for evicted partition: " + cached.partition());
-
- throw e;
- }
- catch (IgniteCheckedException e) {
- U.error(log, "Failed to clear cache entry for evicted partition: " + cached, e);
- }
- finally {
- ctx.database().checkpointReadUnlock();
- }
- }
- }
-
- /**
* Removes all deferred delete requests from {@code rmvQueue}.
*/
public void clearDeferredDeletes() {
