Updated Branches: refs/heads/cassandra-1.2 db8705294 -> 9719b6874
Fix test failures for CASSANDRA-5175 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9719b687 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9719b687 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9719b687 Branch: refs/heads/cassandra-1.2 Commit: 9719b6874c95d47d2c6fc089ce3c52d1d35b9c9e Parents: db87052 Author: Vijay Parthasarathy <[email protected]> Authored: Tue Jan 22 23:48:37 2013 -0800 Committer: Vijay Parthasarathy <[email protected]> Committed: Tue Jan 22 23:48:37 2013 -0800 ---------------------------------------------------------------------- .../cassandra/net/OutboundTcpConnection.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9719b687/src/java/org/apache/cassandra/net/OutboundTcpConnection.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java index 90d054e..9de38d3 100644 --- a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java +++ b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java @@ -133,7 +133,7 @@ public class OutboundTcpConnection extends Thread if (m == CLOSE_SENTINEL) { disconnect(); - if (!isStopped) + if (isStopped) break; continue; }
