svn commit: r1055324 - /cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java

[jbellis]

Author: jbellis
Date: Wed Jan  5 07:09:00 2011
New Revision: 1055324

URL: http://svn.apache.org/viewvc?rev=1055324&view=rev
Log:
make RC.results a ConcurrentMap to emphasize that remove-while-iterating is OK

Modified:
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java?rev=1055324&r1=1055323&r2=1055324&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/ReadResponseResolver.java
 Wed Jan  5 07:09:00 2011
@@ -27,6 +27,7 @@ import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ConcurrentMap;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,7 +45,7 @@ public class ReadResponseResolver implem
 {
        private static Logger logger_ = 
LoggerFactory.getLogger(ReadResponseResolver.class);
     private final String table;
-    private final Map<Message, ReadResponse> results = new 
NonBlockingHashMap<Message, ReadResponse>();
+    private final ConcurrentMap<Message, ReadResponse> results = new 
NonBlockingHashMap<Message, ReadResponse>();
     private DecoratedKey key;
     private ByteBuffer digest;