*/
package org.onap.aai.champcore.graph.impl;
-import java.util.UUID;
+import java.security.SecureRandom;
import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.onap.aai.champcore.ChampCoreMsgs;
import org.onap.aai.champcore.ChampTransaction;
import org.onap.aai.champcore.exceptions.ChampTransactionException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.onap.aai.cl.api.Logger;
+import org.onap.aai.cl.eelf.LoggerFactory;
public class TinkerpopTransaction extends ChampTransaction {
private static final int COMMIT_RETRY_COUNT = 3;
-
+
/** Threaded Tinkerpop transaction. */
protected Graph threadedTransaction;
-
- private static final Logger LOGGER = LoggerFactory.getLogger(TinkerpopTransaction.class);
+
+ private static final Logger LOGGER = LoggerFactory.getInstance().getLogger(TinkerpopTransaction.class);
protected TinkerpopTransaction() { }
-
-
+
+
/**
* Creates a new transaction instance.
- *
+ *
* @param aGraphInstance - Instance of the graph to request the transaction from.
*/
public TinkerpopTransaction(Graph aGraphInstance) {
super();
-
+
if(!aGraphInstance.features().graph().supportsTransactions()) {
throw new UnsupportedOperationException();
}
-
+
// Request a threaded transaction object from the graph.
this.threadedTransaction = aGraphInstance.tx().createThreadedTx();
-
- LOGGER.info("Open transaction - id: " + id);
+
+ LOGGER.info(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_INFO,
+ "Open transaction - id: " + id);
}
-
+
@Override
public String id() {
return id.toString();
}
-
+
public Graph getGraphInstance() {
return threadedTransaction;
}
@Override
public void commit() throws ChampTransactionException {
-
- LOGGER.debug("Commiting transaction - " + id);
-
- final long initialBackoff = (int) (Math.random() * 50);
+
+ LOGGER.debug("Commiting transaction - " + id);
+
+ final long initialBackoff = (int)(new SecureRandom().nextDouble() * 50);
// If something goes wrong, we will retry a couple of times before
// giving up.
for (int i = 0; i < COMMIT_RETRY_COUNT; i++) {
-
+
try {
-
+
// Do the commit.
threadedTransaction.tx().commit();
- LOGGER.info("Committed transaction - id: " + id);
+ LOGGER.info(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_INFO,
+ "Committed transaction - id: " + id);
return;
-
+
} catch (Throwable e) {
-
+
LOGGER.debug("Transaction " + id + " failed to commit due to: " + e.getMessage());
-
+
// Have we used up all of our retries?
if (i == COMMIT_RETRY_COUNT - 1) {
-
- LOGGER.error("Maxed out commit attempt retries, client must handle exception and retry", e);
+
+ LOGGER.error(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_ERROR,
+ "Maxed out commit attempt retries, client must handle exception and retry. " + e.getMessage());
threadedTransaction.tx().rollback();
throw new ChampTransactionException(e);
}
// Calculate how long we will wait before retrying...
final long backoff = (long) Math.pow(2, i) * initialBackoff;
- LOGGER.warn("Caught exception while retrying transaction commit, retrying in " + backoff + " ms");
-
+ LOGGER.warn(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_WARN,
+ "Caught exception while retrying transaction commit, retrying in " + backoff + " ms");
+
// ...and sleep before trying the commit again.
try {
Thread.sleep(backoff);
-
+
} catch (InterruptedException ie) {
-
- LOGGER.info("Interrupted while backing off on transaction commit");
- Thread.interrupted();
+
+ LOGGER.info(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_INFO,
+ "Interrupted while backing off on transaction commit");
+ Thread.currentThread().interrupt();
return;
}
}
@Override
public void rollback() throws ChampTransactionException {
-
- long initialBackoff = (int) (Math.random() * 50);
-
+ long initialBackoff = (int)(new SecureRandom().nextDouble() * 50);
+
+
// If something goes wrong, we will retry a couple of times before
// giving up.
for (int i = 0; i < COMMIT_RETRY_COUNT; i++) {
-
+
try {
-
- threadedTransaction.tx().rollback();
- LOGGER.info("Rolled back transaction - id: " + id);
+
+ threadedTransaction.tx().rollback();
+ LOGGER.info(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_INFO,
+ "Rolled back transaction - id: " + id);
return;
-
+
} catch (Throwable e) {
-
+
LOGGER.debug("Transaction " + id + " failed to roll back due to: " + e.getMessage());
-
+
// Have we used up all of our retries?
if (i == COMMIT_RETRY_COUNT - 1) {
-
- LOGGER.error("Maxed out rollback attempt retries, client must handle exception and retry", e);
+
+ LOGGER.error(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_ERROR,
+ "Maxed out rollback attempt retries, client must handle exception and retry. " + e.getMessage());
throw new ChampTransactionException(e);
}
-
+
// Calculate how long we will wait before retrying...
final long backoff = (long) Math.pow(2, i) * initialBackoff;
- LOGGER.warn("Caught exception while retrying transaction roll back, retrying in " + backoff + " ms");
-
+ LOGGER.warn(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_WARN,
+ "Caught exception while retrying transaction roll back, retrying in " + backoff + " ms");
+
// ...and sleep before trying the commit again.
try {
Thread.sleep(backoff);
-
+
} catch (InterruptedException ie) {
-
- LOGGER.info("Interrupted while backing off on transaction rollback");
- Thread.interrupted();
+
+ LOGGER.info(ChampCoreMsgs.CHAMPCORE_TINKERPOP_TRANSACTION_INFO,
+ "Interrupted while backing off on transaction rollback");
+ Thread.currentThread().interrupt();
return;
}
}