Merge "Update css file name in conf.py"
authorBrendan Tschaen <ctschaen@att.com>
Thu, 28 May 2020 21:40:00 +0000 (21:40 +0000)
committerGerrit Code Review <gerrit@onap.org>
Thu, 28 May 2020 21:40:00 +0000 (21:40 +0000)
music-core/src/main/java/org/onap/music/datastore/jsonobjects/JsonUpdate.java
music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java
music-core/src/main/java/org/onap/music/lockingservice/cassandra/MusicLockState.java
music-core/src/main/java/org/onap/music/main/CipherUtil.java
music-core/src/main/java/org/onap/music/main/DeadlockDetectionUtil.java
music-core/src/main/java/org/onap/music/main/MusicUtil.java
music-core/src/main/java/org/onap/music/service/impl/MusicCassaCore.java

index cd767a4..29fdb1d 100644 (file)
@@ -190,7 +190,6 @@ public class JsonUpdate implements Serializable {
          }
          
          EELFLoggerDelegate.mdcPut("keyspace", "( "+this.getKeyspaceName()+" ) ");
-         long startTime = System.currentTimeMillis();
          String operationId = UUID.randomUUID().toString();  // just for infoging purposes.
          String consistency = this.getConsistencyInfo().get("type");
 
@@ -311,9 +310,6 @@ public class JsonUpdate implements Serializable {
             conditionInfo = new Condition(this.getConditions(), selectQuery);
         }
 
-        ReturnType operationResult = null;
-        long jsonParseCompletionTime = System.currentTimeMillis();
-
         if(consistency.equalsIgnoreCase(MusicUtil.EVENTUAL) && this.getConsistencyInfo().get("consistency") != null) {
             if(MusicUtil.isValidConsistency(this.getConsistencyInfo().get("consistency"))) {
                 queryObject.setConsistency(this.getConsistencyInfo().get("consistency"));
@@ -376,7 +372,7 @@ public class JsonUpdate implements Serializable {
         }
 
         public String getRowIdString() {
-            return this.rowIdString.toString();
+            return this.rowIdString;
         }
 
         public void setRowIdString(String rowIdString) {
index 0c5d39c..9a69a9b 100644 (file)
@@ -503,7 +503,7 @@ public class CassaLockStore {
     }
     
     public List<String> getAllLocksForOwner(String ownerId, String keyspace, String table) throws MusicServiceException, MusicQueryException {
-        List<String> toRet = new ArrayList<String>();
+        List<String> toRet = new ArrayList<>();
         String lockTable = table_prepend_name + table;
         PreparedQueryObject queryObject = new PreparedQueryObject();
         queryObject.appendQueryString("SELECT key, lockreference FROM " + keyspace + "." + lockTable);
index 00187dc..14fb813 100644 (file)
@@ -39,15 +39,18 @@ import org.onap.music.eelf.logging.format.ErrorTypes;
 
 // the state variable that will be stored in the locking service, capturing the transitions of
 public class MusicLockState implements Serializable {
+    // captures the state of the lock
     public enum LockStatus {
         UNLOCKED, BEING_LOCKED, LOCKED
-    };// captures the state of the lock
+    }
+  
 
     private static EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(MusicLockState.class);
     private LockStatus lockStatus;
     private boolean needToSyncQuorum = false;
     private String lockHolder;
-    private long leasePeriod = Long.MAX_VALUE, leaseStartTime = -1;
+    private long leasePeriod = Long.MAX_VALUE;
+    private long leaseStartTime = -1;
     private String errorMessage = null;
     
     public MusicLockState(String errorMessage) {
index 3278dc1..9a8ff69 100644 (file)
@@ -168,7 +168,8 @@ public class CipherUtil {
      */
     public static String encryptPKC(String value, String skey)  {
         Cipher cipher = null;
-        byte[] iv = null, finalByte = null;
+        byte[] iv = null;
+        byte[] finalByte = null;
 
         try {
             cipher = Cipher.getInstance(ALGORYTHM_DETAILS, "SunJCE");
index 23ccca7..004bd55 100644 (file)
@@ -47,7 +47,7 @@ public class DeadlockDetectionUtil {
                public Node(String id) {
                        super();
                        this.id = id;
-                       this.links = new ArrayList<Node>();
+                       this.links = new ArrayList<>();
                }
 
                public List<Node> getLinks() {
@@ -85,7 +85,7 @@ public class DeadlockDetectionUtil {
        }
        
        public DeadlockDetectionUtil() {
-               this.nodeList = new HashMap<String, Node>();
+               this.nodeList = new HashMap<>();
        }
 
        public void listAllNodes() {
@@ -105,8 +105,7 @@ public class DeadlockDetectionUtil {
                        currentNode = nodeList.get("o" + owner);
                }
 
-               boolean cycle = findCycle(currentNode);
-               return cycle;
+               return findCycle(currentNode);
        }
 
        private boolean findCycle(Node currentNode) {
index 865ca01..4b8b105 100644 (file)
@@ -516,7 +516,7 @@ public class MusicUtil {
             case MAP:
                 return (Map<String, Object>) valueObj;
             case LIST:
-                return (List<Object>)valueObj;
+                return valueObj;
             case BLOB:
 
             default:
@@ -525,8 +525,8 @@ public class MusicUtil {
     }
 
     public static ByteBuffer convertToActualDataType(DataType colType, byte[] valueObj) {
-        ByteBuffer buffer = ByteBuffer.wrap(valueObj);
-        return buffer;
+       
+        return ByteBuffer.wrap(valueObj);
     }
 
     /**
@@ -620,11 +620,9 @@ public class MusicUtil {
      * @throws MusicServiceException
      * @throws MusicQueryException
      */
-    public static long v2sTimeStampInMicroseconds(long ordinal, long timeOfWrite) throws MusicServiceException, MusicQueryException {
+    public static long v2sTimeStampInMicroseconds(long ordinal, long timeOfWrite) throws MusicServiceException, MusicQueryException{
         // TODO: use acquire time instead of music eternity epoch
-        long ts = ordinal * MaxLockReferenceTimePart + (timeOfWrite - MusicEternityEpochMillis);
-
-        return ts;
+        return ordinal * MaxLockReferenceTimePart + (timeOfWrite - MusicEternityEpochMillis);
     }
 
     public static MusicCoreService  getMusicCoreService() {
index d29ba32..8055a48 100644 (file)
@@ -1080,9 +1080,10 @@ public class MusicCassaCore implements MusicCoreService {
         ReturnType result = null;
         
         try {
+            
             PreparedQueryObject queryObj = null;
             queryObj = jsonInsertObj.genInsertPreparedQueryObj();
-            
+
             if (consistency.equalsIgnoreCase(MusicUtil.EVENTUAL)) {
                 result = eventualPut(jsonInsertObj.genInsertPreparedQueryObj());
             } else if (consistency.equalsIgnoreCase(MusicUtil.CRITICAL)) {