#630 unlock if exception occurs

Signed-off-by: Jeen Broekstra <jeen.broekstra@gmail.com>
eclipse-rdf4j · Oct 26, 2016 · 3c57552 · 3c57552
1 parent 41aa1ad
commit 3c57552
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/core/sail/nativerdf/src/main/java/org/eclipse/rdf4j/sail/nativerdf/NativeSailStore.java b/core/sail/nativerdf/src/main/java/org/eclipse/rdf4j/sail/nativerdf/NativeSailStore.java
@@ -428,14 +428,21 @@ public void deprecate(Resource subj, IRI pred, Value obj, Resource ctx)
 		private synchronized void acquireExclusiveTransactionLock()
 			throws SailException
 		{
+			boolean txnStarted = false;
 			if (!txnLockManager.isHeldByCurrentThread()) {
 				try {
 					txnLockManager.lock();
 					tripleStore.startTransaction();
+					txnStarted = true;
 				}
 				catch (IOException e) {
 					throw new SailException(e);
 				}
+				finally {
+					if (!txnStarted) {
+						txnLockManager.unlock();
+					}
+				}
 			}
 		}