Implement voluntaryReleaseLock retry logic

Add retry logic for voluntaryReleaseLock inside atomicPut

Change-Id: Iedb474c673541f3f79d4ae4ee76e15f14a387ed7
Issue-ID: MUSIC-148
Signed-off-by: Mohammad Salehe <salehe@cs.toronto.edu>

1 files changed, 17 insertions, 1 deletions

diff --git a/src/main/java/org/onap/music/service/impl/MusicCassaCore.java b/src/main/java/org/onap/music/service/impl/MusicCassaCore.java
index 7eebf65a..e3347486 100644
--- a/src/main/java/org/onap/music/service/impl/MusicCassaCore.java
+++ b/src/main/java/org/onap/music/service/impl/MusicCassaCore.java
@@ -668,7 +668,23 @@ public class MusicCassaCore implements MusicCoreService {
             ReturnType criticalPutResult = criticalPut(keyspaceName, tableName, primaryKey,
                     queryObject, lockReference, conditionInfo);
             long criticalPutTime = System.currentTimeMillis();
-            voluntaryReleaseLock(fullyQualifiedKey, lockReference);
+
+            int releaseTries = 0;
+            while (true) {
+                MusicLockState rs = voluntaryReleaseLock(fullyQualifiedKey, lockReference);
+                releaseTries++;
+                if (rs.getLockStatus() != MusicLockState.LockStatus.UNLOCKED) {
+                    try {
+                        Thread.sleep(Integer.min(100, (int) Math.pow(2, releaseTries - 1)));
+                    } catch (InterruptedException e) {
+                    }
+                } else
+                    break;
+            }
+            if (releaseTries > 1) {
+                System.out.print((char) (Integer.min(releaseTries, 9) + 78));
+            }
+
             long lockDeleteTime = System.currentTimeMillis();
             String timingInfo = "|lock creation time:" + (lockCreationTime - start)
                     + "|lock accquire time:" + (lockAcqTime - lockCreationTime)