// Sequence has already been checked
@Override
- @Nullable TransactionSuccess<?> handleRequest(final TransactionRequest<?> request, final RequestEnvelope envelope,
+ @Nullable TransactionSuccess<?> doHandleRequest(final TransactionRequest<?> request, final RequestEnvelope envelope,
final long now) throws RequestException {
if (request instanceof ModifyTransactionRequest) {
return handleModifyTransaction((ModifyTransactionRequest) request, envelope, now);
} else if (m instanceof TransactionMerge) {
modification.merge(m.getPath(), ((TransactionMerge) m).getData());
} else {
- LOG.warn("{}: ignoring unhandled modification {}", history().persistenceId(), m);
+ LOG.warn("{}: ignoring unhandled modification {}", persistenceId(), m);
}
}
}
coordinatedCommit(envelope, now);
return null;
default:
- LOG.warn("{}: rejecting unsupported protocol {}", history().persistenceId(), maybeProto.get());
+ LOG.warn("{}: rejecting unsupported protocol {}", persistenceId(), maybeProto.get());
throw new UnsupportedRequestException(request);
}
}
// only once.
if (readyCohort == null) {
readyCohort = openTransaction.ready();
- LOG.debug("{}: transitioned {} to ready", history().persistenceId(), openTransaction.getIdentifier());
+ LOG.debug("{}: transitioned {} to ready", persistenceId(), openTransaction.getIdentifier());
openTransaction = null;
}
}