}
EELFLoggerDelegate.mdcPut("keyspace", "( "+this.getKeyspaceName()+" ) ");
- long startTime = System.currentTimeMillis();
String operationId = UUID.randomUUID().toString(); // just for infoging purposes.
String consistency = this.getConsistencyInfo().get("type");
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"));
}
public String getRowIdString() {
- return this.rowIdString.toString();
+ return this.rowIdString;
}
public void setRowIdString(String rowIdString) {
}
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);
package org.onap.music.lockingservice.cassandra;
import java.util.HashSet;
-import java.util.List;
import java.util.Set;
import org.onap.music.datastore.MusicDataStoreHandle;
import org.onap.music.datastore.PreparedQueryObject;
import org.onap.music.eelf.logging.EELFLoggerDelegate;
-import org.onap.music.exceptions.MusicQueryException;
import org.onap.music.exceptions.MusicServiceException;
import org.onap.music.main.MusicCore;
import org.onap.music.main.MusicUtil;
// 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) {
*/
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");