Wait 10s instead of 1s for connections to be closed on StreamingTransferTest
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/315356c1 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/315356c1 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/315356c1 Branch: refs/heads/cassandra-3.8 Commit: 315356c1de7e4d7db5e0f159daebe9a528a8e04d Parents: 91f7387 Author: Paulo Motta <pauloricard...@gmail.com> Authored: Fri Aug 12 10:57:29 2016 -0300 Committer: Jason Brown <jasedbr...@gmail.com> Committed: Sun Aug 14 08:42:58 2016 -0700 ---------------------------------------------------------------------- .../unit/org/apache/cassandra/streaming/StreamingTransferTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/315356c1/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java ---------------------------------------------------------------------- diff --git a/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java b/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java index 2b16267..0af76c2 100644 --- a/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java +++ b/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java @@ -255,7 +255,7 @@ public class StreamingTransferTest { //after stream session is finished, message handlers may take several milliseconds to be closed outer: - for (int i = 0; i <= 10; i++) + for (int i = 0; i <= 100; i++) { for (MessagingService.SocketThread socketThread : MessagingService.instance().getSocketThreads()) if (!socketThread.connections.isEmpty())