Make locks dynamic based on TTL of lock table

CHANGES.md

@@ -2,6 +2,7 @@
 
 ## Version 5.0.0 (Not yet released)
 
+* Make locks dynamic based on TTL of lock table - Issue #543
 * Add new repair type parallel_vnode - Issue #554
 * Add validation of repair interval and alarms - Issue #560
 * Insert into repair history only on session finish - Issue #565

application/src/main/java/com/ericsson/bss/cassandra/ecchronos/application/ECChronosInternals.java

@@ -17,6 +17,7 @@
 import com.datastax.oss.driver.api.core.CqlSession;
 import com.datastax.oss.driver.api.core.metadata.Node;
 import com.ericsson.bss.cassandra.ecchronos.application.config.Config;
+import com.ericsson.bss.cassandra.ecchronos.application.config.lockfactory.CasLockFactoryConfig;
 import com.ericsson.bss.cassandra.ecchronos.connection.JmxConnectionProvider;
 import com.ericsson.bss.cassandra.ecchronos.connection.NativeConnectionProvider;
 import com.ericsson.bss.cassandra.ecchronos.connection.StatementDecorator;
@@ -75,11 +76,15 @@ public ECChronosInternals(final Config configuration,
                 .withJmxProxyFactory(myJmxProxyFactory)
                 .build();
 
+        CasLockFactoryConfig casLockFactoryConfig = configuration.getLockFactory()
+                .getCasLockFactoryConfig();
+
         myLockFactory = CASLockFactory.builder()
                 .withNativeConnectionProvider(nativeConnectionProvider)
                 .withHostStates(myHostStatesImpl)
                 .withStatementDecorator(statementDecorator)
-                .withKeyspaceName(configuration.getLockFactory().getCasLockFactoryConfig().getKeyspaceName())
+                .withKeyspaceName(casLockFactoryConfig.getKeyspaceName())
+                .withCacheExpiryInSeconds(casLockFactoryConfig.getFailureCacheExpiryTimeInSeconds())
                 .build();
 
         Node node = nativeConnectionProvider.getLocalNode();
@@ -221,9 +226,9 @@ public void remainingRepairTime(final TableReference tableReference, final long
 
         @Override
         public void repairSession(final TableReference tableReference,
-                                 final long timeTaken,
-                                 final TimeUnit timeUnit,
-                                 final boolean successful)
+                                  final long timeTaken,
+                                  final TimeUnit timeUnit,
+                                  final boolean successful)
         {
             if (LOG.isTraceEnabled())
             {

application/src/main/java/com/ericsson/bss/cassandra/ecchronos/application/config/lockfactory/CasLockFactoryConfig.java

@@ -18,15 +18,28 @@
 
 public class CasLockFactoryConfig
 {
-    private String myKeyspaceName = "ecchronos";
+    private static final long DEFAULT_EXPIRY_TIME_IN_SECONDS = 30L;
+    private static final String DEFAULT_KEYSPACE_NAME = "ecchronos";
+    private String myKeyspaceName = DEFAULT_KEYSPACE_NAME;
+    private long myExpiryTimeInSeconds = DEFAULT_EXPIRY_TIME_IN_SECONDS;
+
+    public final long getFailureCacheExpiryTimeInSeconds()
+    {
+        return myExpiryTimeInSeconds;
+    }
+
+    @JsonProperty ("cache_expiry_time_in_seconds")
+    public final void setFailureCacheExpiryTimeInSeconds(final long expiryTimeInSeconds)
+    {
+        myExpiryTimeInSeconds = expiryTimeInSeconds;
+    }
 
-    @JsonProperty("keyspace")
     public final String getKeyspaceName()
     {
         return myKeyspaceName;
     }
 
-    @JsonProperty("keyspace")
+    @JsonProperty ("keyspace")
     public final void setKeyspaceName(final String keyspaceName)
     {
         myKeyspaceName = keyspaceName;

application/src/main/resources/ecc.yml

@@ -237,6 +237,13 @@ lock_factory:
     ## The keyspace used for the CAS lock factory tables.
     ##
     keyspace: ecchronos
+    ##
+    ## The number of seconds until the lock failure cache expires.
+    ## If an attempt to secure a lock is unsuccessful,
+    ## all subsequent attempts will be failed until
+    ## the cache expiration time is reached.
+    ##
+    cache_expiry_time_in_seconds: 30
 
 run_policy:
   time_based:

application/src/test/java/com/ericsson/bss/cassandra/ecchronos/application/config/TestCasLockFactoryConfig.java

@@ -0,0 +1,53 @@
+/*
+ * Copyright 2023 Telefonaktiebolaget LM Ericsson
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.ericsson.bss.cassandra.ecchronos.application.config;
+
+import com.ericsson.bss.cassandra.ecchronos.application.config.lockfactory.CasLockFactoryConfig;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
+import org.junit.Test;
+
+import java.io.File;
+import java.io.IOException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class TestCasLockFactoryConfig
+{
+    @Test
+    public void testCasLockFactoryConfigWithProvidedValue() throws IOException
+    {
+        CasLockFactoryConfig casLockFactoryConfig = getCasLockFactoryConfig("all_set.yml");
+        assertThat(casLockFactoryConfig.getKeyspaceName()).isEqualTo("ecc");
+        assertThat(casLockFactoryConfig.getFailureCacheExpiryTimeInSeconds()).isEqualTo(100L);
+    }
+
+    @Test
+    public void testCasLockFactoryConfigDefaultValue() throws IOException
+    {
+        CasLockFactoryConfig casLockFactoryConfig = getCasLockFactoryConfig("nothing_set.yml");
+        assertThat(casLockFactoryConfig.getKeyspaceName()).isEqualTo("ecchronos");
+        assertThat(casLockFactoryConfig.getFailureCacheExpiryTimeInSeconds()).isEqualTo(30L);
+    }
+
+    private CasLockFactoryConfig getCasLockFactoryConfig(final String fileName) throws IOException
+    {
+        ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
+        File file = new File(classLoader.getResource(fileName).getFile());
+        ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
+        Config config = mapper.readValue(file, Config.class);
+        return config.getLockFactory().getCasLockFactoryConfig();
+    }
+}

application/src/test/resources/all_set.yml

@@ -79,6 +79,8 @@ statistics:
 lock_factory:
   cas:
     keyspace: ecc
+    cache_expiry_time_in_seconds: 100
+
 
 run_policy:
   time_based: