You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@cassandra.apache.org by jb...@apache.org on 2011/02/03 17:01:32 UTC

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

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