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 <brandonwilli...@apache.org> Authored: Fri Oct 18 14:33:05 2013 -0500 Committer: Brandon Williams <brandonwilli...@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); }