You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2012/09/26 17:05:37 UTC
[2/3] git commit: fix listEndpointsPendingHints to generate String
representation of the tokens for which we have hints
fix listEndpointsPendingHints to generate String representation of the tokens for which we have hints
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b03ae12c
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b03ae12c
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b03ae12c
Branch: refs/heads/trunk
Commit: b03ae12cb58da9bc77dc88151da47d26223051de
Parents: ee4a26d
Author: Jonathan Ellis <jb...@apache.org>
Authored: Wed Sep 26 10:03:57 2012 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Wed Sep 26 10:03:57 2012 -0500
----------------------------------------------------------------------
.../apache/cassandra/db/HintedHandOffManager.java | 19 +++++++--------
1 files changed, 9 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b03ae12c/src/java/org/apache/cassandra/db/HintedHandOffManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/HintedHandOffManager.java b/src/java/org/apache/cassandra/db/HintedHandOffManager.java
index 3e5e2d5..a26894e 100644
--- a/src/java/org/apache/cassandra/db/HintedHandOffManager.java
+++ b/src/java/org/apache/cassandra/db/HintedHandOffManager.java
@@ -446,32 +446,31 @@ public class HintedHandOffManager implements HintedHandOffManagerMBean
public List<String> listEndpointsPendingHints()
{
- List<Row> rows = getHintsSlice(1);
+ Token.TokenFactory tokenFactory = StorageService.getPartitioner().getTokenFactory();
// Extract the keys as strings to be reported.
LinkedList<String> result = new LinkedList<String>();
- for (Row r : rows)
+ for (Row row : getHintsSlice(1))
{
- if (r.cf != null) //ignore removed rows
- result.addFirst(new String(r.key.key.array()));
+ if (row.cf != null) //ignore removed rows
+ result.addFirst(tokenFactory.toString(row.key.token));
}
return result;
}
public Map<String, Integer> countPendingHints()
{
- List<Row> rows = getHintsSlice(Integer.MAX_VALUE);
+ Token.TokenFactory tokenFactory = StorageService.getPartitioner().getTokenFactory();
Map<String, Integer> result = new HashMap<String, Integer>();
- Token.TokenFactory tokenFactory = StorageService.getPartitioner().getTokenFactory();
- for (Row r : rows)
+ for (Row row : getHintsSlice(Integer.MAX_VALUE))
{
- if (r.cf == null) // ignore removed rows
+ if (row.cf == null) // ignore removed rows
continue;
- int count = r.cf.getColumnCount();
+ int count = row.cf.getColumnCount();
if (count > 0)
- result.put(tokenFactory.toString(r.key.token), count);
+ result.put(tokenFactory.toString(row.key.token), count);
}
return result;
}