natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix awaitTermination logic for streamExecutors 

patch by Christopher Porter; reviewed by jbellis for CASSANDRA-4484
This commit is contained in:
Jonathan Ellis 2012-08-02 12:53:21 -05:00
parent 4a6d9888b4
commit afb2c00e58
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/cassandra/net/MessagingService.java
View File

@ -644,7 +644,7 @@ public final class MessagingService implements MessagingServiceMBean
for (DebuggableThreadPoolExecutor e : streamExecutors.values())
{
if (e.awaitTermination(24, TimeUnit.HOURS))
if (!e.awaitTermination(24, TimeUnit.HOURS))
logger.error("Stream took more than 24H to complete; skipping");
}
}