Browse files

replace LBQ with CLQ in RangeSliceResponseResolver

  • Loading branch information...
1 parent 576efcd commit 4ab0dacade95fcca81d032d5b23fb40d45606325 @jbellis jbellis committed Apr 10, 2013
Showing with 8 additions and 4 deletions.
  1. +8 −4 src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
View
12 src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
@@ -19,15 +19,19 @@
import java.net.InetAddress;
import java.util.*;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ConcurrentLinkedQueue;
+
import com.google.common.collect.AbstractIterator;
-import org.apache.cassandra.db.*;
+import org.apache.cassandra.db.ColumnFamily;
+import org.apache.cassandra.db.DecoratedKey;
+import org.apache.cassandra.db.RangeSliceReply;
+import org.apache.cassandra.db.Row;
import org.apache.cassandra.net.AsyncOneResponse;
import org.apache.cassandra.net.MessageIn;
-import org.apache.cassandra.utils.Pair;
import org.apache.cassandra.utils.CloseableIterator;
import org.apache.cassandra.utils.MergeIterator;
+import org.apache.cassandra.utils.Pair;
/**
* Turns RangeSliceReply objects into row (string -> CF) maps, resolving
@@ -45,7 +49,7 @@ public int compare(Pair<Row, InetAddress> o1, Pair<Row, InetAddress> o2)
private final String table;
private List<InetAddress> sources;
- protected final Collection<MessageIn<RangeSliceReply>> responses = new LinkedBlockingQueue<MessageIn<RangeSliceReply>>();;
+ protected final Collection<MessageIn<RangeSliceReply>> responses = new ConcurrentLinkedQueue<MessageIn<RangeSliceReply>>();
public final List<AsyncOneResponse> repairResults = new ArrayList<AsyncOneResponse>();
public RangeSliceResponseResolver(String table)

0 comments on commit 4ab0dac

Please sign in to comment.