debugging slowdowns
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0be5deaa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0be5deaa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0be5deaa Branch: refs/heads/ignite-1.5-cache-get-opts Commit: 0be5deaa14ec81af29437702b9f468d8d5f5a891 Parents: f2258cc Author: Yakov Zhdanov <[email protected]> Authored: Thu Nov 26 00:22:46 2015 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Thu Nov 26 00:22:46 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtCacheAdapter.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0be5deaa/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java index 8a293d7..50fabe9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java @@ -23,7 +23,6 @@ import java.util.Collection; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; -import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.NoSuchElementException; @@ -725,9 +724,7 @@ public abstract class GridDhtCacheAdapter<K, V> extends GridDistributedCacheAdap final CacheExpiryPolicy expiryPlc = CacheExpiryPolicy.forAccess(ttl); - LinkedHashMap<KeyCacheObject, Boolean> map = U.newLinkedHashMap(1); - - map.put(req.key(), req.addReader()); + Map<KeyCacheObject, Boolean> map = Collections.singletonMap(req.key(), req.addReader()); IgniteInternalFuture<Collection<GridCacheEntryInfo>> fut = getDhtAsync(nodeId, @@ -760,7 +757,8 @@ public abstract class GridDhtCacheAdapter<K, V> extends GridDistributedCacheAdap info.key(null); res0 = info; - } else if (req.needVersion()) + } + else if (req.needVersion()) res0 = new CacheVersionedValue(info.value(), info.version()); else res0 = info.value();
