# ignite-51

Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/caa0039f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/caa0039f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/caa0039f

Branch: refs/heads/ignite-45
Commit: caa0039f65a017a7aeef426cea7c9230c73993e6
Parents: a5e9abc
Author: sboikov <sboi...@gridgain.com>
Authored: Wed Mar 11 11:42:03 2015 +0300
Committer: sboikov <sboi...@gridgain.com>
Committed: Wed Mar 11 11:42:03 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/GridCacheEvictionManager.java  | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/caa0039f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java
index 46b758d..953d15a 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionManager.java
@@ -58,7 +58,7 @@ import static org.jdk8.backport.ConcurrentLinkedDeque8.*;
 /**
  * Cache eviction manager.
  */
-public class GridCacheEvictionManager<K, V> extends GridCacheManagerAdapter<K, 
V> {
+public class GridCacheEvictionManager extends GridCacheManagerAdapter {
     /** Unsafe instance. */
     private static final sun.misc.Unsafe unsafe = GridUnsafe.unsafe();
 
@@ -129,7 +129,7 @@ public class GridCacheEvictionManager<K, V> extends 
GridCacheManagerAdapter<K, V
     @Override public void start0() throws IgniteCheckedException {
         CacheConfiguration cfg = cctx.config();
 
-        plc = cctx.isNear() ? cfg.<K, V>getNearEvictionPolicy() : cfg.<K, 
V>getEvictionPolicy();
+        plc = cctx.isNear() ? cfg.getNearEvictionPolicy() : 
cfg.getEvictionPolicy();
 
         memoryMode = cctx.config().getMemoryMode();
 
@@ -619,7 +619,7 @@ public class GridCacheEvictionManager<K, V> extends 
GridCacheManagerAdapter<K, V
             log.debug("Evicting key locally [key=" + key + ", ver=" + ver + ", 
obsoleteVer=" + obsoleteVer +
                 ", localNode=" + cctx.localNode() + ']');
 
-        GridCacheAdapter<K, V> cache = near ? cctx.dht().near() : cctx.cache();
+        GridCacheAdapter cache = near ? cctx.dht().near() : cctx.cache();
 
         GridCacheEntryEx entry = cache.peekEx(key);
 
@@ -650,7 +650,7 @@ public class GridCacheEvictionManager<K, V> extends 
GridCacheManagerAdapter<K, V
      * @throws IgniteCheckedException If failed to evict entry.
      */
     private boolean evict0(
-        GridCacheAdapter<K, V> cache,
+        GridCacheAdapter cache,
         GridCacheEntryEx entry,
         GridCacheVersion obsoleteVer,
         @Nullable CacheEntryPredicate[] filter,
@@ -909,7 +909,7 @@ public class GridCacheEvictionManager<K, V> extends 
GridCacheManagerAdapter<K, V
      * @param obsoleteVer Obsolete version.
      * @throws IgniteCheckedException In case of error.
      */
-    public void batchEvict(Collection<? extends K> keys, @Nullable 
GridCacheVersion obsoleteVer) throws IgniteCheckedException {
+    public void batchEvict(Collection<?> keys, @Nullable GridCacheVersion 
obsoleteVer) throws IgniteCheckedException {
         assert !evictSyncAgr;
         assert cctx.isSwapOrOffheapEnabled();
 
@@ -919,12 +919,12 @@ public class GridCacheEvictionManager<K, V> extends 
GridCacheManagerAdapter<K, V
 
         boolean recordable = 
cctx.events().isRecordable(EVT_CACHE_ENTRY_EVICTED);
 
-        GridCacheAdapter<K, V> cache = cctx.cache();
+        GridCacheAdapter cache = cctx.cache();
 
-        Map<K, GridCacheEntryEx> cached = U.newLinkedHashMap(keys.size());
+        Map<Object, GridCacheEntryEx> cached = U.newLinkedHashMap(keys.size());
 
         // Get all participating entries to avoid deadlock.
-        for (K k : keys) {
+        for (Object k : keys) {
             KeyCacheObject cacheKey = cctx.toCacheKeyObject(k);
 
             GridCacheEntryEx e = cache.peekEx(cacheKey);

Reply via email to