Fixing a bug where a concurrenthashmap is needed instead of a normal hashmap.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/4faf00c4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/4faf00c4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/4faf00c4 Branch: refs/heads/apache-blur-0.2 Commit: 4faf00c411d9f0f36c41fb8f78f447b48cd08e99 Parents: b0cc3e2 Author: Aaron McCurry <[email protected]> Authored: Tue Mar 11 20:45:50 2014 -0400 Committer: Aaron McCurry <[email protected]> Committed: Tue Mar 11 20:45:50 2014 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/blur/server/ShardServerContext.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4faf00c4/blur-core/src/main/java/org/apache/blur/server/ShardServerContext.java ---------------------------------------------------------------------- diff --git a/blur-core/src/main/java/org/apache/blur/server/ShardServerContext.java b/blur-core/src/main/java/org/apache/blur/server/ShardServerContext.java index e86d2d6..a605af4 100644 --- a/blur-core/src/main/java/org/apache/blur/server/ShardServerContext.java +++ b/blur-core/src/main/java/org/apache/blur/server/ShardServerContext.java @@ -20,7 +20,6 @@ import java.io.Closeable; import java.io.IOException; import java.net.SocketAddress; import java.util.Collection; -import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; @@ -39,7 +38,7 @@ public class ShardServerContext extends BlurServerContext implements ServerConte private static final Log LOG = LogFactory.getLog(ShardServerContext.class); private final static Map<Thread, ShardServerContext> _threadsToContext = new ConcurrentHashMap<Thread, ShardServerContext>(); - private final Map<String, IndexSearcherClosable> _indexSearcherMap = new HashMap<String, IndexSearcherClosable>(); + private final Map<String, IndexSearcherClosable> _indexSearcherMap = new ConcurrentHashMap<String, IndexSearcherClosable>(); public ShardServerContext(SocketAddress localSocketAddress, SocketAddress remoteSocketAddress) { super(localSocketAddress, remoteSocketAddress);
