commit fd69a6b5951226025fb54adacf471b32f7ccc416
author kisskys <kisskys@eaa15691-b419-025a-1212-ee371bd00084> Sat Apr 06 00:05:19 2013 +0000
committer kisskys <kisskys@eaa15691-b419-025a-1212-ee371bd00084> Sat Apr 06 00:05:19 2013 +0000
tree 2282dbee98f80c667a40b39c20ed8036c76c10f8
parent c0c6d332f9ddf526b24931f05ab037b3e38cfb75

fixing another bug in LockManager

git-svn-id: https://asterixdb.googlecode.com/svn/branches/asterix_lsm_stabilization@1539 eaa15691-b419-025a-1212-ee371bd00084

asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/JobInfo.java

diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/JobInfo.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/JobInfo.java
index 75ff349..4f01f37 100644
--- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/JobInfo.java
+++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/JobInfo.java
@@ -186,7 +186,7 @@
     public void increaseDatasetISLockCount(int datasetId) {
         int count = datasetISLockHT.get(datasetId);
         if (count == -1) {
-            datasetISLockHT.upsert(datasetId, 1);
+            datasetISLockHT.put(datasetId, 1);
         } else {
             datasetISLockHT.upsert(datasetId, count + 1);
         }
@@ -201,7 +201,7 @@
         } else if (count == 1) {
             datasetISLockHT.remove(datasetId);
         } else if (count <= 0) {
-            throw new IllegalStateException("Illegal state of datasetLock count in JobInfo's dLockHT");
+            throw new IllegalStateException("Illegal state of datasetLock count(" + count + ") in JobInfo's dLockHT");
         }
     }