From afb2c00e5864e9a7b60a1ff4b60740c321faee28 Mon Sep 17 00:00:00 2001
From: Jonathan Ellis <jbellis@apache.org>
Date: Thu, 2 Aug 2012 12:53:21 -0500
Subject: [PATCH] fix awaitTermination logic for streamExecutors patch by
 Christopher Porter; reviewed by jbellis for CASSANDRA-4484

---
 src/java/org/apache/cassandra/net/MessagingService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java
index 2fd72cfc86..0fea18148c 100644
--- a/src/java/org/apache/cassandra/net/MessagingService.java
+++ b/src/java/org/apache/cassandra/net/MessagingService.java
@@ -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");
         }
     }