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