Merge branch 'cassandra-1.2' into cassandra-2.0
Conflicts:
src/java/org/apache/cassandra/service/StorageService.java
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/81286b0c
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/81286b0c
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/81286b0c
Branch: refs/heads/trunk
Commit: 81286b0ca2fb5c667d89280b2a7955b2531975c3
Parents: 367c741 4e67631
Author: Brandon Williams <[email protected]>
Authored: Tue May 27 18:12:25 2014 -0500
Committer: Brandon Williams <[email protected]>
Committed: Tue May 27 18:12:25 2014 -0500
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/StorageService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/81286b0c/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/service/StorageService.java
index 45bceb5,8e7c073..d261a47
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@@ -768,9 -738,8 +768,9 @@@ public class StorageService extends Not
InetAddress existing =
tokenMetadata.getEndpoint(token);
if (existing != null)
{
- if
(Gossiper.instance.getEndpointStateForEndpoint(existing).getUpdateTimestamp() >
(System.currentTimeMillis() - delay))
+ long nanoDelay = delay * 1000000L;
+ if
(Gossiper.instance.getEndpointStateForEndpoint(existing).getUpdateTimestamp() >
(System.nanoTime() - nanoDelay))
- throw new
UnsupportedOperationException("Cannnot replace a live node... ");
+ throw new
UnsupportedOperationException("Cannot replace a live node... ");
current.add(existing);
}
else
