453454455456457458459460461462463
abort(e); } throw e; } if (state == State.ABORTED) { throw new TransactionAbortedException( "Transaction has been aborted: " + abortCause, abortCause); } } state = State.COMMITTING; for (TransactionParticipant participant : participants) {
532533534535536537538539540541542
abort(e); } throw e; } if (state == State.ABORTED) { throw new TransactionAbortedException( "Transaction has been aborted: " + abortCause, abortCause); } } }
115116117118119120121122123124125
public void testRunRetryable() { SimpleRetryIoRunnable retry = new SimpleRetryIoRunnable(100, 0) { protected String callOnce() throws IOException { calls++; if (calls == 1) { throw new TransactionAbortedException(""); } return "ok"; } }; retry.run();
455456457458459460461462463464465
534535536537538539540541542543544