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: [email protected]
For additional commands, e-mail: [email protected]
