summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main/java/com/amazon/carbonado/repo/logging/LoggingRepository.java9
-rw-r--r--src/main/java/com/amazon/carbonado/repo/logging/LoggingTransaction.java13
2 files changed, 13 insertions, 9 deletions
diff --git a/src/main/java/com/amazon/carbonado/repo/logging/LoggingRepository.java b/src/main/java/com/amazon/carbonado/repo/logging/LoggingRepository.java
index e196993..4032313 100644
--- a/src/main/java/com/amazon/carbonado/repo/logging/LoggingRepository.java
+++ b/src/main/java/com/amazon/carbonado/repo/logging/LoggingRepository.java
@@ -45,6 +45,9 @@ class LoggingRepository implements Repository, LogAccessCapability {
private final StoragePool mStoragePool;
+ private final ThreadLocal<LoggingTransaction> mActiveTxn =
+ new ThreadLocal<LoggingTransaction>();
+
LoggingRepository(AtomicReference<Repository> rootRef,
Repository actual, Log log)
{
@@ -73,21 +76,21 @@ class LoggingRepository implements Repository, LogAccessCapability {
public Transaction enterTransaction() {
mLog.write("Repository.enterTransaction()");
- return new LoggingTransaction(mLog, mRepo.enterTransaction(), false);
+ return new LoggingTransaction(mActiveTxn, mLog, mRepo.enterTransaction(), false);
}
public Transaction enterTransaction(IsolationLevel level) {
if (mLog.isEnabled()) {
mLog.write("Repository.enterTransaction(" + level + ')');
}
- return new LoggingTransaction(mLog, mRepo.enterTransaction(level), false);
+ return new LoggingTransaction(mActiveTxn, mLog, mRepo.enterTransaction(level), false);
}
public Transaction enterTopTransaction(IsolationLevel level) {
if (mLog.isEnabled()) {
mLog.write("Repository.enterTopTransaction(" + level + ')');
}
- return new LoggingTransaction(mLog, mRepo.enterTopTransaction(level), true);
+ return new LoggingTransaction(mActiveTxn, mLog, mRepo.enterTopTransaction(level), true);
}
public IsolationLevel getTransactionIsolationLevel() {
diff --git a/src/main/java/com/amazon/carbonado/repo/logging/LoggingTransaction.java b/src/main/java/com/amazon/carbonado/repo/logging/LoggingTransaction.java
index 2fe9865..fd88f35 100644
--- a/src/main/java/com/amazon/carbonado/repo/logging/LoggingTransaction.java
+++ b/src/main/java/com/amazon/carbonado/repo/logging/LoggingTransaction.java
@@ -31,24 +31,25 @@ import com.amazon.carbonado.Transaction;
* @author Brian S O'Neill
*/
class LoggingTransaction implements Transaction {
- private static final ThreadLocal<LoggingTransaction> mActiveTxn =
- new ThreadLocal<LoggingTransaction>();
-
private static final AtomicLong mNextID = new AtomicLong();
+ private final ThreadLocal<LoggingTransaction> mActiveTxn;
private final LoggingTransaction mParent;
private final Log mLog;
private final Transaction mTxn;
private final long mID;
private final boolean mTop;
- LoggingTransaction(Log log, Transaction txn, boolean top) {
- mParent = mActiveTxn.get();
+ LoggingTransaction(ThreadLocal<LoggingTransaction> activeTxn,
+ Log log, Transaction txn, boolean top)
+ {
+ mActiveTxn = activeTxn;
+ mParent = activeTxn.get();
mLog = log;
mTxn = txn;
mID = mNextID.addAndGet(1);
mTop = top;
- mActiveTxn.set(this);
+ activeTxn.set(this);
mLog.write("Entered transaction: " + idChain());
}