提交 90d325f8 authored 作者: Andrei Tokar's avatar Andrei Tokar

minor improvement in exception handling during rollback

上级 4ef104af
...@@ -395,6 +395,7 @@ public class Transaction { ...@@ -395,6 +395,7 @@ public class Transaction {
try { try {
store.rollbackTo(this, logId, savepointId); store.rollbackTo(this, logId, savepointId);
} finally { } finally {
notifyAllWaitingTransactions();
long expectedState = composeState(STATUS_ROLLING_BACK, logId, hasRollback(lastState)); long expectedState = composeState(STATUS_ROLLING_BACK, logId, hasRollback(lastState));
long newState = composeState(STATUS_OPEN, savepointId, true); long newState = composeState(STATUS_OPEN, savepointId, true);
if (!statusAndLogId.compareAndSet(expectedState, newState)) { if (!statusAndLogId.compareAndSet(expectedState, newState)) {
...@@ -404,7 +405,6 @@ public class Transaction { ...@@ -404,7 +405,6 @@ public class Transaction {
"while rollback to savepoint was in progress", "while rollback to savepoint was in progress",
transactionId); transactionId);
} }
notifyAllWaitingTransactions();
} }
} }
...@@ -412,14 +412,26 @@ public class Transaction { ...@@ -412,14 +412,26 @@ public class Transaction {
* Roll the transaction back. Afterwards, this transaction is closed. * Roll the transaction back. Afterwards, this transaction is closed.
*/ */
public void rollback() { public void rollback() {
Throwable ex = null;
try { try {
long lastState = setStatus(STATUS_ROLLED_BACK); long lastState = setStatus(STATUS_ROLLED_BACK);
long logId = getLogId(lastState); long logId = getLogId(lastState);
if (logId > 0) { if (logId > 0) {
store.rollbackTo(this, logId, 0); store.rollbackTo(this, logId, 0);
} }
} catch (Throwable e) {
ex = e;
throw e;
} finally { } finally {
try {
store.endTransaction(this, true); store.endTransaction(this, true);
} catch (Throwable e) {
if (ex == null) {
throw e;
} else {
ex.addSuppressed(e);
}
}
} }
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论