svn commit: r1066845 - /cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java

[jbellis]

Author: jbellis
Date: Thu Feb  3 16:01:31 2011
New Revision: 1066845

URL: http://svn.apache.org/viewvc?rev=1066845&view=rev
Log:
add debug log message for missing callback
patch by Aaron Morton and jbellis for CASSANDRA-2081

Modified:
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java?rev=1066845&r1=1066844&r2=1066845&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/ResponseVerbHandler.java
 Thu Feb  3 16:01:31 2011
@@ -37,7 +37,10 @@ public class ResponseVerbHandler impleme
         double age = System.currentTimeMillis() - 
MessagingService.instance().getRegisteredCallbackAge(messageId);
         Pair<InetAddress, IMessageCallback> pair = 
MessagingService.instance().removeRegisteredCallback(messageId);
         if (pair == null)
+        {
+            logger_.debug("Callback already removed for {}", messageId);
             return;
+        }
 
         IMessageCallback cb = pair.right;
         MessagingService.instance().maybeAddLatency(cb, message.getFrom(), 
age);