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 <dbros...@apache.org> Authored: Sun Jun 2 22:02:23 2013 -0400 Committer: Dave Brosius <dbros...@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);
