You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2013/10/18 21:34:47 UTC
[2/3] git commit: millis->nanos
millis->nanos
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2bc30e4b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2bc30e4b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2bc30e4b
Branch: refs/heads/trunk
Commit: 2bc30e4ba50f8f21d357d88ae4cf70e15df270bd
Parents: 99bef9d
Author: Brandon Williams <br...@apache.org>
Authored: Fri Oct 18 14:33:05 2013 -0500
Committer: Brandon Williams <br...@apache.org>
Committed: Fri Oct 18 14:33:05 2013 -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/2bc30e4b/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index 4065c9e..62f0907 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -685,7 +685,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
InetAddress existing = tokenMetadata.getEndpoint(token);
if (existing != null)
{
- if (Gossiper.instance.getEndpointStateForEndpoint(existing).getUpdateTimestamp() > (System.currentTimeMillis() - delay))
+ if (Gossiper.instance.getEndpointStateForEndpoint(existing).getUpdateTimestamp() > (System.nanoTime() - delay*1000))
throw new UnsupportedOperationException("Cannnot replace a live node... ");
current.add(existing);
}