cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1186204 - in /cassandra/branches/cassandra-0.8: CHANGES.txt src/java/org/apache/cassandra/net/MessagingService.java
Date Wed, 19 Oct 2011 13:28:02 GMT
Author: jbellis
Date: Wed Oct 19 13:28:01 2011
New Revision: 1186204

URL: http://svn.apache.org/viewvc?rev=1186204&view=rev
Log:
correct dropped messages logging
patch by jbellis; reviewed by brandonwilliams for CASSANDRA-3377

Modified:
    cassandra/branches/cassandra-0.8/CHANGES.txt
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/MessagingService.java

Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1186204&r1=1186203&r2=1186204&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Wed Oct 19 13:28:01 2011
@@ -23,6 +23,7 @@
    (CASSANDRA-3170)
  * fix changing durable_writes keyspace option during CF creation
    (CASSANDRA-3292)
+ * correct dropped messages logging (CASSANDRA-3377)
 
 
 0.8.7

Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/MessagingService.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/MessagingService.java?rev=1186204&r1=1186203&r2=1186204&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/MessagingService.java
(original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/MessagingService.java
Wed Oct 19 13:28:01 2011
@@ -609,7 +609,8 @@ public final class MessagingService impl
             if (recent > 0)
             {
                 logTpstats = true;
-                logger_.info("{} {} messages dropped in server lifetime", recent, verb);
+                logger_.info("{} {} messages dropped in last {}ms",
+                             new Object[] {recent, verb, LOG_DROPPED_INTERVAL_IN_MS});
                 lastDroppedInternal.put(verb, dropped.get());
             }
         }



Mime
View raw message