Remove duplicate logging of sending MerkleTree request

Patch by Marcus Olsson; reviewed by marcuse for CASSANDRA-11486


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1ff9df75
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1ff9df75
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1ff9df75

Branch: refs/heads/trunk
Commit: 1ff9df75c46edb02bf1f994e7ecc651e29b277fb
Parents: 2ed8555
Author: Marcus Olsson <marcus.ols...@ericsson.com>
Authored: Thu Mar 24 15:06:23 2016 +0100
Committer: Marcus Eriksson <marc...@apache.org>
Committed: Mon Apr 4 13:54:00 2016 +0200

----------------------------------------------------------------------
 src/java/org/apache/cassandra/repair/RepairJob.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/1ff9df75/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 754e26f..a92233b 100644
--- a/src/java/org/apache/cassandra/repair/RepairJob.java
+++ b/src/java/org/apache/cassandra/repair/RepairJob.java
@@ -94,7 +94,6 @@ public class RepairJob extends AbstractFuture<RepairResult> 
implements Runnable
             {
                 public ListenableFuture<List<TreeResponse>> 
apply(List<InetAddress> endpoints) throws Exception
                 {
-                    logger.info(String.format("[repair #%s] requesting merkle 
trees for %s (to %s)", desc.sessionId, desc.columnFamily, endpoints));
                     if (parallelismDegree == RepairParallelism.SEQUENTIAL)
                         return sendSequentialValidationRequest(endpoints);
                     else
@@ -104,7 +103,6 @@ public class RepairJob extends AbstractFuture<RepairResult> 
implements Runnable
         }
         else
         {
-            logger.info(String.format("[repair #%s] requesting merkle trees 
for %s (to %s)", desc.sessionId, desc.columnFamily, allEndpoints));
             // If not sequential, just send validation request to all replica
             validations = sendValidationRequest(allEndpoints);
         }
@@ -197,6 +195,9 @@ public class RepairJob extends AbstractFuture<RepairResult> 
implements Runnable
      */
     private ListenableFuture<List<TreeResponse>> 
sendSequentialValidationRequest(Collection<InetAddress> endpoints)
     {
+        String message = String.format("Requesting merkle trees for %s (to 
%s)", desc.columnFamily, endpoints);
+        logger.info("[repair #{}] {}", desc.sessionId, message);
+        Tracing.traceRepair(message);
         int gcBefore = 
Keyspace.open(desc.keyspace).getColumnFamilyStore(desc.columnFamily).gcBefore(System.currentTimeMillis());
         List<ListenableFuture<TreeResponse>> tasks = new 
ArrayList<>(endpoints.size());
 
@@ -236,6 +237,9 @@ public class RepairJob extends AbstractFuture<RepairResult> 
implements Runnable
      */
     private ListenableFuture<List<TreeResponse>> 
sendDCAwareValidationRequest(Collection<InetAddress> endpoints)
     {
+        String message = String.format("Requesting merkle trees for %s (to 
%s)", desc.columnFamily, endpoints);
+        logger.info("[repair #{}] {}", desc.sessionId, message);
+        Tracing.traceRepair(message);
         int gcBefore = 
Keyspace.open(desc.keyspace).getColumnFamilyStore(desc.columnFamily).gcBefore(System.currentTimeMillis());
         List<ListenableFuture<TreeResponse>> tasks = new 
ArrayList<>(endpoints.size());
 

Reply via email to