- private void handleTransactionAbort(final TransactionAbortRequest request,
- final RequestEnvelope envelope, final long now) throws RequestException {
+ private void handleLocalTransactionAbort(final long sequence, final RequestEnvelope envelope, final long now) {
+ Preconditions.checkState(readyCohort == null, "Transaction {} encountered local abort with commit underway",
+ getIdentifier());
+ openTransaction.abort(() -> recordAndSendSuccess(envelope, now, new TransactionAbortSuccess(getIdentifier(),
+ sequence)));
+ }
+
+ private void handleTransactionAbort(final long sequence, final RequestEnvelope envelope, final long now) {