re-add expiration check

NucleoTeam · Jan 28, 2024 · fef3c30 · fef3c30
1 parent 9a4f92f
commit fef3c30
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 14 deletions.
diff --git a/build.gradle b/build.gradle
@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.15.10'
+version = '1.15.11'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/com/nucleodb/library/database/lock/LockManager.java b/src/main/java/com/nucleodb/library/database/lock/LockManager.java
@@ -101,19 +101,19 @@ public void run() {
     @Override
     public Object put(@NotNull Object key, @NotNull Object value) {
       executorPool.schedule(()->{
-//        LockReference lockReference = (LockReference)this.get(key);
-//        if(lockReference!=null && value instanceof LockReference && lockReference.getRequest().equals(((LockReference)value).getRequest())) {
-//          logger.info( "EXPIRED");
-//          logger.info((String) key);
-//          try {
-//            LockReference activeLock = Serializer.getObjectMapper().getOm().readValue(Serializer.getObjectMapper().getOm().writeValueAsString(value), LockReference.class);
-//            activeLock.setLock(false);
-//            lockAction(activeLock);
-//          } catch (JsonProcessingException e) {
-//            e.printStackTrace();
-//          }
-//        }
-      }, 10000, TimeUnit.MILLISECONDS);
+        LockReference lockReference = (LockReference)this.get(key);
+        if(lockReference!=null && value instanceof LockReference && lockReference.getRequest().equals(((LockReference)value).getRequest())) {
+          logger.info( "EXPIRED");
+          logger.info((String) key);
+          try {
+            LockReference activeLock = Serializer.getObjectMapper().getOm().readValue(Serializer.getObjectMapper().getOm().writeValueAsString(value), LockReference.class);
+            activeLock.setLock(false);
+            lockAction(activeLock);
+          } catch (JsonProcessingException e) {
+            e.printStackTrace();
+          }
+        }
+      }, 1000, TimeUnit.MILLISECONDS);
       return super.put(key, value);
     }
   };