Author: brandonwilliams Date: Thu Mar 24 18:59:31 2011 New Revision: 1085074
URL: http://svn.apache.org/viewvc?rev=1085074&view=rev Log: Log a message when a streaming action for an unkown session is received instead of NPE. Patch by brandonwilliams, reviewed by jbellis for CASSANDRA-2377 Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java?rev=1085074&r1=1085073&r2=1085074&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java Thu Mar 24 18:59:31 2011 @@ -46,6 +46,11 @@ public class StreamReplyVerbHandler impl StreamReply reply = StreamReply.serializer.deserialize(new DataInputStream(bufIn)); logger.debug("Received StreamReply {}", reply); StreamOutSession session = StreamOutSession.get(message.getFrom(), reply.sessionId); + if (session == null) + { + logger.debug("Received stream action " + reply.action + " for an unknown session from " + message.getFrom()); + return; + } switch (reply.action) {
