Merge branch 'cassandra-5.0' into trunk

Author: beobal

CHANGES.txt

@@ -255,6 +255,7 @@
  * Add the ability to disable bulk loading of SSTables (CASSANDRA-18781)
  * Clean up obsolete functions and simplify cql_version handling in cqlsh (CASSANDRA-18787)
 Merged from 5.0:
+ * Correctly calculate default for FailureDetector max interval (CASSANDRA-21025)
  * Adding missing configs in system_views.settings to be backward compatible (CASSANDRA-20863)
  * Heap dump should not be generated on handled exceptions (CASSANDRA-20974)
  * Fix range queries on early-open BTI files (CASSANDRA-20976)

src/java/org/apache/cassandra/gms/FailureDetector.java

@@ -43,6 +43,7 @@
 import javax.management.openmbean.TabularDataSupport;
 import javax.management.openmbean.TabularType;
 
+import com.google.common.annotations.VisibleForTesting;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -444,6 +445,16 @@ public UnknownEndpointException(InetAddressAndPort ep)
         {
             super("Unknown endpoint: " + ep);
         }
+
+    /**
+     * Only for testing. In production code, ArrivalWindow instances call getMaxInterval() during
+     * intitialization and use the value to set the private final field MAX_INTERVAL_IN_NANO
+     * @return the value that would be used for to populate any new ArrivalWindow instance
+     */
+    @VisibleForTesting
+    static long calculateMaxInterval()
+    {
+        return ArrivalWindow.getMaxInterval();
     }
 }
 
@@ -514,9 +525,10 @@ class ArrivalWindow
         arrivalIntervals = new ArrayBackedBoundedStats(size);
     }
 
-    private static long getMaxInterval()
+    @VisibleForTesting
+    static long getMaxInterval()
     {
-        long newValue = FD_MAX_INTERVAL_MS.getLong(FailureDetector.INITIAL_VALUE_NANOS);
+        long newValue = FD_MAX_INTERVAL_MS.getLong(TimeUnit.NANOSECONDS.toMillis(FailureDetector.INITIAL_VALUE_NANOS));
         if (newValue != FailureDetector.INITIAL_VALUE_NANOS)
             logger.info("Overriding {} from {}ms to {}ms", FD_MAX_INTERVAL_MS.getKey(), FailureDetector.INITIAL_VALUE_NANOS, newValue);
         return TimeUnit.NANOSECONDS.convert(newValue, TimeUnit.MILLISECONDS);

test/unit/org/apache/cassandra/gms/FailureDetectorTest.java

@@ -22,12 +22,14 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
+import java.util.concurrent.TimeUnit;
 
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import org.apache.cassandra.ServerTestUtils;
 import org.apache.cassandra.Util;
+import org.apache.cassandra.config.CassandraRelevantProperties;
 import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.db.commitlog.CommitLog;
 import org.apache.cassandra.dht.RandomPartitioner;
@@ -37,6 +39,7 @@
 import org.apache.cassandra.tcm.ClusterMetadata;
 
 import static org.apache.cassandra.config.CassandraRelevantProperties.MAX_LOCAL_PAUSE_IN_MS;
+import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 
 public class FailureDetectorTest
@@ -79,4 +82,36 @@ public void testConvictAfterLeft() throws UnknownHostException
         FailureDetector.instance.interpret(leftHost);
         assertFalse("Left endpoint not convicted", FailureDetector.instance.isAlive(leftHost));
     }
+
+    @Test
+    public void testMaxIntervalCalculation()
+    {
+        // Default value for ArrivalWindow.MAX_INTERVAL_IN_NANO, which is supplied by
+        // ArrivalWindow::getMaxInterval should be 2000000000ns/2 seconds.
+        Long initialPropertyValue = CassandraRelevantProperties.FD_MAX_INTERVAL_MS.isPresent()
+                                    ? CassandraRelevantProperties.FD_MAX_INTERVAL_MS.getLong()
+                                    : null;
+        try
+        {
+            // verify that max interval isn't being set directly using system property
+            CassandraRelevantProperties.FD_MAX_INTERVAL_MS.reset();
+            assertFalse(CassandraRelevantProperties.FD_MAX_INTERVAL_MS.isPresent());
+            // in which case, max interval should default to INITIAL_VALUE_NANOS
+            assertEquals(FailureDetector.INITIAL_VALUE_NANOS, FailureDetector.calculateMaxInterval());
+
+            // max interval can be overridden, but it's value should be supplied in millis
+            long overrideMillis = TimeUnit.NANOSECONDS.toMillis(FailureDetector.INITIAL_VALUE_NANOS * 2);
+            CassandraRelevantProperties.FD_MAX_INTERVAL_MS.setLong(overrideMillis);
+            // max interval is a nanos value, so convert the override to get the expected value
+            long expectedNanos = TimeUnit.NANOSECONDS.convert(overrideMillis, TimeUnit.MILLISECONDS);
+            assertEquals(expectedNanos, FailureDetector.calculateMaxInterval());
+        }
+        finally
+        {
+            if (initialPropertyValue == null)
+                CassandraRelevantProperties.FD_MAX_INTERVAL_MS.reset();
+            else
+                CassandraRelevantProperties.FD_MAX_INTERVAL_MS.setLong(initialPropertyValue);
+        }
+    }
 }