cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1169951 - /cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
Date Mon, 12 Sep 2011 21:50:56 GMT
Author: jbellis
Date: Mon Sep 12 21:50:56 2011
New Revision: 1169951

URL: http://svn.apache.org/viewvc?rev=1169951&view=rev
Log:
add some more logging around version inference
patch by jbellis

Modified:
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java

Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java?rev=1169951&r1=1169950&r2=1169951&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
(original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
Mon Sep 12 21:50:56 2011
@@ -80,6 +80,7 @@ public class IncomingTcpConnection exten
             return;
         }
 
+        logger.debug("version is {}", version);
         if (version > MessagingService.version_)
         {
             // save the endpoint so gossip will reconnect to it
@@ -100,6 +101,7 @@ public class IncomingTcpConnection exten
         {
             // only set version when <= to us, otherwise it's the responsibility of the
other end to mimic us
             Gossiper.instance.setVersion(socket.getInetAddress(), version);
+            logger.debug("set version for {} to {}", socket.getInetAddress(), version);
         }
 
         while (true)
@@ -132,12 +134,17 @@ public class IncomingTcpConnection exten
                         Message message = Message.serializer().deserialize(dis, version);
                         MessagingService.instance().receive(message, id);
                     }
+                    else
+                    {
+                        logger.debug("Ignoring message version {}", version);
+                    }
                 }
                 // prepare to read the next message
                 MessagingService.validateMagic(input.readInt());
                 int header = input.readInt();
                 assert isStream == (MessagingService.getBits(header, 3, 1) == 1) : "Connections
cannot change type: " + isStream;
                 version = MessagingService.getBits(header, 15, 8);
+                logger.debug("Version is now {}", version);
             }
             catch (EOFException e)
             {



Mime
View raw message