[GitHub] cassandra pull request #94: CASSANDRA-10726: Read repair inserts should use ...

[tedcarroll <gi...@git.apache.org>]

Github user tedcarroll commented on a diff in the pull request:

    https://github.com/apache/cassandra/pull/94#discussion_r198575430
  
    --- Diff: src/java/org/apache/cassandra/service/DataResolver.java ---
    @@ -40,18 +40,26 @@
     import org.apache.cassandra.exceptions.ReadTimeoutException;
     import org.apache.cassandra.net.*;
     import org.apache.cassandra.tracing.Tracing;
    -import org.apache.cassandra.utils.FBUtilities;
    +import org.apache.cassandra.utils.Pair;
     
     public class DataResolver extends ResponseResolver
     {
    -    @VisibleForTesting
    -    final List<AsyncOneResponse> repairResults = Collections.synchronizedList(new ArrayList<>());
    +    private final Map<AsyncOneResponse, Pair<MessageOut, InetAddress>> repairResponseRequestMap = new HashMap<>();
    --- End diff --
    
    Should be a ConcurrentHashMap.


---

---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org