- LocalHistorySuccess destroy(final long sequence, final long now) throws RequestException {
- if (state != State.CLOSED) {
- LOG.debug("{}: closing history {}", persistenceId(), getIdentifier());
-
- // FIXME: add any finalization as needed
- state = State.CLOSED;
- }
-
- // FIXME: record a DESTROY tombstone in the journal
- return new LocalHistorySuccess(getIdentifier(), sequence);
- }
-
- boolean isDestroyed() {
- return state == State.CLOSED;
- }
-
- private void checkDeadTransaction(final TransactionIdentifier id) throws RequestException {
- // FIXME: check if this history is still open
- // FIXME: check if the last transaction has been submitted
-
- // Transaction identifiers within a local history have to have increasing IDs
- if (lastSeenTransaction != null && Long.compareUnsigned(lastSeenTransaction, id.getTransactionId()) >= 0) {
- throw new DeadTransactionException(lastSeenTransaction);
- }
+ @Override
+ ShardDataTreeCohort createReadyCohort(final TransactionIdentifier id, final DataTreeModification mod) {
+ return chain.createReadyCohort(id, mod);