Repository: cassandra Updated Branches: refs/heads/trunk 25a0a7130 -> 630e47ba4
use parameterized logging Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/630e47ba Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/630e47ba Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/630e47ba Branch: refs/heads/trunk Commit: 630e47ba4cd7fe7264f7373b3432ca96a38a6610 Parents: 25a0a71 Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Fri Nov 28 21:53:29 2014 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Fri Nov 28 21:53:29 2014 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/repair/RepairJob.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/630e47ba/src/java/org/apache/cassandra/repair/RepairJob.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/repair/RepairJob.java b/src/java/org/apache/cassandra/repair/RepairJob.java index 34b4217..708ee70 100644 --- a/src/java/org/apache/cassandra/repair/RepairJob.java +++ b/src/java/org/apache/cassandra/repair/RepairJob.java @@ -203,7 +203,7 @@ public class RepairJob extends AbstractFuture<RepairResult> implements Runnable Queue<InetAddress> requests = new LinkedList<>(endpoints); InetAddress address = requests.poll(); ValidationTask firstTask = new ValidationTask(desc, address, gcBefore); - logger.info("Validating " + address); + logger.info("Validating {}", address); session.waitForValidation(Pair.create(desc, address), firstTask); tasks.add(firstTask); ValidationTask currentTask = firstTask; @@ -216,7 +216,7 @@ public class RepairJob extends AbstractFuture<RepairResult> implements Runnable { public void onSuccess(TreeResponse result) { - logger.info("Validating " + nextAddress); + logger.info("Validating {}", nextAddress); session.waitForValidation(Pair.create(desc, nextAddress), nextTask); taskExecutor.execute(nextTask); } @@ -257,7 +257,7 @@ public class RepairJob extends AbstractFuture<RepairResult> implements Runnable Queue<InetAddress> requests = entry.getValue(); InetAddress address = requests.poll(); ValidationTask firstTask = new ValidationTask(desc, address, gcBefore); - logger.info("Validating " + address); + logger.info("Validating {}", address); session.waitForValidation(Pair.create(desc, address), firstTask); tasks.add(firstTask); ValidationTask currentTask = firstTask; @@ -270,7 +270,7 @@ public class RepairJob extends AbstractFuture<RepairResult> implements Runnable { public void onSuccess(TreeResponse result) { - logger.info("Validating " + nextAddress); + logger.info("Validating {}", nextAddress); session.waitForValidation(Pair.create(desc, nextAddress), nextTask); taskExecutor.execute(nextTask); }
