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()); } }