*/
package org.opendaylight.controller.cluster.datastore;
+import static com.google.common.base.Preconditions.checkArgument;
+import static java.util.Objects.requireNonNull;
+
import akka.actor.ActorSelection;
-import com.google.common.base.Preconditions;
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
-import org.opendaylight.controller.sal.core.spi.data.AbstractSnapshotBackedTransactionChain;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreWriteTransaction;
-import org.opendaylight.controller.sal.core.spi.data.SnapshotBackedWriteTransaction;
-import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree;
+import org.opendaylight.mdsal.dom.spi.store.AbstractSnapshotBackedTransactionChain;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadWriteTransaction;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreWriteTransaction;
+import org.opendaylight.mdsal.dom.spi.store.SnapshotBackedWriteTransaction;
import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification;
import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeSnapshot;
+import org.opendaylight.yangtools.yang.data.api.schema.tree.ReadOnlyDataTree;
/**
* Transaction chain instantiated on top of a locally-available DataTree. It does not instantiate
private static final Throwable ABORTED = new Throwable("Transaction aborted");
private final TransactionChainProxy parent;
private final ActorSelection leader;
- private final DataTree tree;
+ private final ReadOnlyDataTree tree;
- LocalTransactionChain(final TransactionChainProxy parent, final ActorSelection leader, final DataTree tree) {
- this.parent = Preconditions.checkNotNull(parent);
- this.leader = Preconditions.checkNotNull(leader);
- this.tree = Preconditions.checkNotNull(tree);
+ LocalTransactionChain(final TransactionChainProxy parent, final ActorSelection leader,
+ final ReadOnlyDataTree tree) {
+ this.parent = requireNonNull(parent);
+ this.leader = requireNonNull(leader);
+ this.tree = requireNonNull(tree);
}
- DataTree getDataTree() {
+ ReadOnlyDataTree getDataTree() {
return tree;
}
@Override
protected DOMStoreThreePhaseCommitCohort createCohort(
final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
- final DataTreeModification modification) {
- return new LocalChainThreePhaseCommitCohort(transaction, modification);
+ final DataTreeModification modification,
+ final Exception operationError) {
+ return new LocalChainThreePhaseCommitCohort(transaction, modification, operationError);
}
@Override
@SuppressWarnings({"unchecked", "checkstyle:IllegalCatch"})
@Override
- public LocalThreePhaseCommitCohort onTransactionReady(@Nonnull DOMStoreWriteTransaction tx,
- @Nullable Exception operationError) {
- Preconditions.checkArgument(tx instanceof SnapshotBackedWriteTransaction);
+ public LocalThreePhaseCommitCohort onTransactionReady(DOMStoreWriteTransaction tx, Exception operationError) {
+ checkArgument(tx instanceof SnapshotBackedWriteTransaction);
if (operationError != null) {
return new LocalChainThreePhaseCommitCohort((SnapshotBackedWriteTransaction<TransactionIdentifier>)tx,
operationError);
private class LocalChainThreePhaseCommitCohort extends LocalThreePhaseCommitCohort {
protected LocalChainThreePhaseCommitCohort(SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
- DataTreeModification modification) {
- super(parent.getActorContext(), leader, transaction, modification);
+ DataTreeModification modification, Exception operationError) {
+ super(parent.getActorUtils(), leader, transaction, modification, operationError);
}
protected LocalChainThreePhaseCommitCohort(SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
Exception operationError) {
- super(parent.getActorContext(), leader, transaction, operationError);
+ super(parent.getActorUtils(), leader, transaction, operationError);
}
@Override