You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2013/06/03 04:02:52 UTC
git commit: don't declare throwing exceptions that aren't thrown
Updated Branches:
refs/heads/trunk 3d1e29bd1 -> 88f2ebc5f
don't declare throwing exceptions that aren't thrown
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/88f2ebc5
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/88f2ebc5
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/88f2ebc5
Branch: refs/heads/trunk
Commit: 88f2ebc5fe2a31bd4bf79aaaab87a455421f6e11
Parents: 3d1e29b
Author: Dave Brosius <db...@apache.org>
Authored: Sun Jun 2 22:02:23 2013 -0400
Committer: Dave Brosius <db...@apache.org>
Committed: Sun Jun 2 22:02:23 2013 -0400
----------------------------------------------------------------------
.../org/apache/cassandra/db/BatchlogManager.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/88f2ebc5/src/java/org/apache/cassandra/db/BatchlogManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/BatchlogManager.java b/src/java/org/apache/cassandra/db/BatchlogManager.java
index 48d86e3..9d46739 100644
--- a/src/java/org/apache/cassandra/db/BatchlogManager.java
+++ b/src/java/org/apache/cassandra/db/BatchlogManager.java
@@ -203,7 +203,7 @@ public class BatchlogManager implements BatchlogManagerMBean
* We try to deliver the mutations to the replicas ourselves if they are alive and only resort to writing hints
* when a replica is down or a write request times out.
*/
- private void replaySerializedMutation(RowMutation mutation, long writtenAt) throws IOException
+ private void replaySerializedMutation(RowMutation mutation, long writtenAt)
{
int ttl = calculateHintTTL(mutation, writtenAt);
if (ttl <= 0)
@@ -211,7 +211,7 @@ public class BatchlogManager implements BatchlogManagerMBean
Set<InetAddress> liveEndpoints = new HashSet<InetAddress>();
String ks = mutation.getTable();
- Token tk = StorageService.getPartitioner().getToken(mutation.key());
+ Token<?> tk = StorageService.getPartitioner().getToken(mutation.key());
for (InetAddress endpoint : Iterables.concat(StorageService.instance.getNaturalEndpoints(ks, tk),
StorageService.instance.getTokenMetadata().pendingEndpointsFor(tk, ks)))
{
@@ -227,7 +227,7 @@ public class BatchlogManager implements BatchlogManagerMBean
attemptDirectDelivery(mutation, writtenAt, liveEndpoints);
}
- private void attemptDirectDelivery(RowMutation mutation, long writtenAt, Set<InetAddress> endpoints) throws IOException
+ private void attemptDirectDelivery(RowMutation mutation, long writtenAt, Set<InetAddress> endpoints)
{
List<WriteResponseHandler> handlers = Lists.newArrayList();
final CopyOnWriteArraySet<InetAddress> undelivered = new CopyOnWriteArraySet<InetAddress>(endpoints);