cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [5/6] git commit: cleanup logger.debug too
Date Tue, 18 Jun 2013 13:55:05 GMT
cleanup logger.debug too


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

Branch: refs/heads/cassandra-1.2
Commit: e5c34d7c29e9ec6dc162210b90fc69ea11a4c331
Parents: 0c81eae
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Tue Jun 18 08:51:39 2013 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Tue Jun 18 08:51:39 2013 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/service/StorageProxy.java | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/e5c34d7c/src/java/org/apache/cassandra/service/StorageProxy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java
index adb3f2d..c12cace 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -861,7 +861,7 @@ public class StorageProxy implements StorageProxyMBean
             ReadCallback<ReadResponse, Row>[] readCallbacks = new ReadCallback[commands.size()];
 
             if (!commandsToRetry.isEmpty())
-                logger.debug("Retrying {} commands", commandsToRetry.size());
+                Tracing.trace("Retrying {} commands", commandsToRetry.size());
 
             // send out read requests
             for (int i = 0; i < commands.size(); i++)
@@ -947,7 +947,7 @@ public class StorageProxy implements StorageProxyMBean
                 }
                 catch (DigestMismatchException ex)
                 {
-                    logger.debug("Digest mismatch: {}", ex.toString());
+                    Tracing.trace("Digest mismatch: {}", ex.toString());
                     
                     ReadRepairMetrics.repairedBlocking.mark();
                     
@@ -963,9 +963,10 @@ public class StorageProxy implements StorageProxyMBean
                     repairCommands.add(command);
                     repairResponseHandlers.add(repairHandler);
 
+                    MessageOut<ReadCommand> message = command.createMessage();
                     for (InetAddress endpoint : handler.endpoints)
                     {
-                        MessageOut<ReadCommand> message = command.createMessage();
+                        Tracing.trace("Enqueuing full data read to {}", endpoint);
                         MessagingService.instance().sendRR(message, endpoint, repairHandler);
                     }
                 }
@@ -1009,7 +1010,7 @@ public class StorageProxy implements StorageProxyMBean
                     ReadCommand retryCommand = command.maybeGenerateRetryCommand(resolver,
row);
                     if (retryCommand != null)
                     {
-                        logger.debug("Issuing retry for read command");
+                        Tracing.trace("Issuing retry for read command");
                         if (commandsToRetry == Collections.EMPTY_LIST)
                             commandsToRetry = new ArrayList<ReadCommand>();
                         commandsToRetry.add(retryCommand);
@@ -1193,7 +1194,7 @@ public class StorageProxy implements StorageProxyMBean
                     MessageOut<RangeSliceCommand> message = nodeCmd.createMessage();
                     for (InetAddress endpoint : filteredEndpoints)
                     {
-                        logger.trace("Enqueuing request to {}", endpoint);
+                        Tracing.trace("Enqueuing request to {}", endpoint);
                         MessagingService.instance().sendRR(message, endpoint, handler);
                     }
                 }


Mime
View raw message