Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-558

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881282 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
jbellis committed Nov 17, 2009
1 parent a5bd08f commit 6c37fb8
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -206,11 +206,11 @@ public WriteResponseHandler getWriteResponseHandler(int blockFor, int consistenc
{
if (consistency_level == ConsistencyLevel.DCQUORUM)
{
return new DatacenterQuorumResponseHandler(locQFactor);
return new DatacenterWriteResponseHandler(locQFactor);
}
else if (consistency_level == ConsistencyLevel.DCQUORUMSYNC)
{
return new DatacenterQuorumSyncResponseHandler(getQuorumRepFactor());
return new DatacenterSyncWriteResponseHandler(getQuorumRepFactor());
}
return super.getWriteResponseHandler(blockFor, consistency_level);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,12 @@
* provided in the input map. it will block till we recive response from
* n nodes in each of our data centers.
*/
public class DatacenterQuorumSyncResponseHandler extends WriteResponseHandler
public class DatacenterSyncWriteResponseHandler extends WriteResponseHandler
{
private final Map<String, Integer> dcResponses = new HashMap<String, Integer>();
private final Map<String, Integer> responseCounts;

public DatacenterQuorumSyncResponseHandler(Map<String, Integer> responseCounts)
public DatacenterSyncWriteResponseHandler(Map<String, Integer> responseCounts)
{
// Response is been managed by the map so make it 1 for the superclass.
super(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,13 @@
* provided in the input map. it will block till we recive response from (DC, n)
* nodes.
*/
public class DatacenterQuorumResponseHandler extends WriteResponseHandler
public class DatacenterWriteResponseHandler extends WriteResponseHandler
{
private int blockFor;
private IEndPointSnitch endpointsnitch;
private InetAddress localEndpoint;

public DatacenterQuorumResponseHandler(int blockFor)
public DatacenterWriteResponseHandler(int blockFor)
{
// Response is been managed by the map so the waitlist size really doesnt matter.
super(blockFor);
Expand Down

0 comments on commit 6c37fb8

Please sign in to comment.