cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1196961 - /cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java
Date Thu, 03 Nov 2011 06:25:26 GMT
Author: jbellis
Date: Thu Nov  3 06:25:26 2011
New Revision: 1196961

URL: http://svn.apache.org/viewvc?rev=1196961&view=rev
Log:
revert unreviewed code

Modified:
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java

Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java?rev=1196961&r1=1196960&r2=1196961&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java
(original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/RowRepairResolver.java
Thu Nov  3 06:25:26 2011
@@ -78,7 +78,8 @@ public class RowRepairResolver extends A
         if (versions.size() > 1)
         {
             resolved = resolveSuperset(versions);
-            logger.debug("versions merged to {}", resolved);
+            if (logger.isDebugEnabled())
+                logger.debug("versions merged");
             // resolved can be null even if versions doesn't have all nulls because of the
call to removeDeleted in resolveSuperSet
             if (resolved != null)
                 maybeScheduleRepairs(resolved, table, key, versions, endpoints);
@@ -103,11 +104,7 @@ public class RowRepairResolver extends A
         {
             ColumnFamily diffCf = ColumnFamily.diff(versions.get(i), resolved);
             if (diffCf == null) // no repair needs to happen
-            {
-                if (logger.isDebugEnabled())
-                    logger.debug("{} has the most recent version", endpoints.get(i));
                 continue;
-            }
 
             // create and send the row mutation message based on the diff
             RowMutation rowMutation = new RowMutation(table, key.key);
@@ -121,8 +118,6 @@ public class RowRepairResolver extends A
             {
                 throw new IOError(e);
             }
-            if (logger.isDebugEnabled())
-                logger.debug("read repair sending {} to {}", rowMutation, endpoints.get(i));
             MessagingService.instance().sendOneWay(repairMessage, endpoints.get(i));
         }
     }



Mime
View raw message