Fix deadlock recovery.

1 files changed, 2 insertions, 3 deletions

diff --git a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBStorage.java b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBStorage.java
index 7332a61..be5982b 100644
--- a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBStorage.java
+++ b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBStorage.java
@@ -817,9 +817,9 @@ abstract class BDBStorage<Txn, S extends Storable> implements Storage<S>, Storag
             try {

                 Transaction txn;

                 if (top) {

-                    txn = mRepository.enterTopTransaction(IsolationLevel.READ_COMMITTED);

+                    txn = repo.enterTopTransaction(IsolationLevel.READ_COMMITTED);

                 } else {

-                    txn = mRepository.enterTransaction(IsolationLevel.READ_COMMITTED);

+                    txn = repo.enterTransaction(IsolationLevel.READ_COMMITTED);

                 }

 

                 txn.setForUpdate(true);

@@ -956,7 +956,6 @@ abstract class BDBStorage<Txn, S extends Storable> implements Storage<S>, Storag
         boolean[] nullable = null;

 

         if (typeDescriptor != null) {

-            System.out.println(typeDescriptor);

             types = new TypeDesc[count];

             nullable = new boolean[count];