svn commit: r904677 - /incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java

[jbellis]

Author: jbellis
Date: Fri Jan 29 23:47:14 2010
New Revision: 904677

URL: http://svn.apache.org/viewvc?rev=904677&view=rev
Log:
avoid setting up completion handler for no-op stream in non-bootstrap mode.  
patch by jbellis; reviewed by gdusbabek for CASSANDRA-750

Modified:
    
incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java

Modified: 
incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java?rev=904677&r1=904676&r2=904677&view=diff
==============================================================================
--- 
incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java
 (original)
+++ 
incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/io/Streaming.java
 Fri Jan 29 23:47:14 2010
@@ -173,11 +173,12 @@
                 StreamInitiateMessage biMsg = 
StreamInitiateMessage.serializer().deserialize(bufIn);
                 StreamContextManager.StreamContext[] streamContexts = 
biMsg.getStreamContext();
 
-                if (streamContexts.length == 0 && 
StorageService.instance().isBootstrapMode())
+                if (streamContexts.length == 0)
                 {
                     if (logger.isDebugEnabled())
                         logger.debug("no data needed from " + 
message.getFrom());
-                    
StorageService.instance().removeBootstrapSource(message.getFrom(), new 
String(message.getHeader(Streaming.TABLE_NAME)));
+                    if (StorageService.instance().isBootstrapMode())
+                        
StorageService.instance().removeBootstrapSource(message.getFrom(), new 
String(message.getHeader(Streaming.TABLE_NAME)));
                     return;
                 }