DML operation auto timeout in 60 seconds

Author: sanketsarang

bean-manager/src/main/java/com/blobcity/lib/query/QueryType.java

@@ -118,12 +118,12 @@ public enum QueryType {
     DROP_NODE("DROP-NODE"),
 
     // INTERNAL QUERIES
-    ROLLBACK("ROLLBACK"),
-    COMMIT("COMMIT"), //this is a confirmation to commit the soft commit
-    SOFT_COMMIT_SUCCESS("SOFT_COMMIT_SUCCESS"),
-    COMMIT_SUCCESS("COMMIT_SUCCESS"),
-    ROLLBACK_SUCCESS("ROLLBACK_SUCCESS"),
-    QUERY_RESPONSE("QUERY_RESPONSE"), //response for select / read queries
+    ROLLBACK("R"),
+    COMMIT("C"), //this is a confirmation to commit the soft commit
+    SOFT_COMMIT_SUCCESS("SCS"),
+    COMMIT_SUCCESS("CS"),
+    ROLLBACK_SUCCESS("RS"),
+    QUERY_RESPONSE("QR"), //response for select / read queries
     PING("PING"), //ping on on-going commit to check if thigns are still running
     MEM_FLUSH("MEM-FLUSH"); //flush a memory table to disk
 

engine/src/main/java/com/blobcity/db/master/AbstractCommitMaster.java

@@ -31,6 +31,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
+import org.apache.mina.util.ConcurrentHashSet;
 import org.json.JSONObject;
 import org.springframework.context.ApplicationContext;
 
@@ -42,6 +43,8 @@
  */
 public abstract class AbstractCommitMaster implements MasterExecutable {
 
+    public static final Set<String> activeQueries = new ConcurrentHashSet<>();
+
     protected final Query query;
     protected final ApplicationContext applicationContext;
     protected final Semaphore semaphore = new Semaphore(0);
@@ -74,7 +77,7 @@ protected ClusterMessaging clusterMessagingBeanInstance() {
 
     protected void awaitCompletion() {
         try {
-            semaphore.tryAcquire(60, TimeUnit.SECONDS); //waits 60 seconds
+            semaphore.tryAcquire( 60, TimeUnit.SECONDS); //waits 60 seconds
             semaphore.release(); // release the immediately last acquire, as the semaphore is no longer required
         } catch (InterruptedException e) {
             System.out.println("Insert timed out");