handleTransactionAbort((TransactionAbortRequest) request, envelope, now);
return null;
} else {
+ LOG.warn("Rejecting unsupported request {}", request);
throw new UnsupportedRequestException(request);
}
}
});
}
- private void successfulDirectCanCommit(final RequestEnvelope envelope, final long startTime) {
+ void successfulDirectCanCommit(final RequestEnvelope envelope, final long startTime) {
readyCohort.preCommit(new FutureCallback<DataTreeCandidate>() {
@Override
public void onSuccess(final DataTreeCandidate result) {
});
}
- private void successfulDirectPreCommit(final RequestEnvelope envelope, final long startTime) {
+ void successfulDirectPreCommit(final RequestEnvelope envelope, final long startTime) {
readyCohort.commit(new FutureCallback<UnsignedLong>() {
@Override
public void onSuccess(final UnsignedLong result) {
});
}
- private void successfulCommit(final RequestEnvelope envelope, final long startTime) {
+ void successfulCommit(final RequestEnvelope envelope, final long startTime) {
recordAndSendSuccess(envelope, startTime, new TransactionCommitSuccess(readyCohort.getIdentifier(),
envelope.getMessage().getSequence()));
readyCohort = null;
coordinatedCommit(envelope, now);
return null;
default:
+ LOG.warn("{}: rejecting unsupported protocol {}", history().persistenceId(), maybeProto.get());
throw new UnsupportedRequestException(request);
}
}