import com.google.common.base.Preconditions;
import com.google.common.primitives.UnsignedLong;
import com.google.common.util.concurrent.FutureCallback;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.datastore.ShardCommitCoordinator.CohortDecorator;
import org.opendaylight.controller.cluster.datastore.modification.Modification;
private CohortEntry(final ReadWriteShardDataTreeTransaction transaction, final short clientVersion) {
this.transaction = Preconditions.checkNotNull(transaction);
- this.transactionId = transaction.getId();
+ this.transactionId = transaction.getIdentifier();
this.clientVersion = clientVersion;
}
cohort.commit(callback);
}
- void abort() throws InterruptedException, ExecutionException, TimeoutException {
- cohort.abort().get();
+ void abort(final FutureCallback<Void> callback) {
+ cohort.abort(callback);
}
void ready(final CohortDecorator cohortDecorator) {