*/
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.yangtools.yang.data.api.schema.tree.DataTreeModification;
-import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeSnapshot;
+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.tree.api.DataTreeModification;
+import org.opendaylight.yangtools.yang.data.tree.api.DataTreeSnapshot;
+import org.opendaylight.yangtools.yang.data.tree.api.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
- public DOMStoreReadTransaction newReadOnlyTransaction(TransactionIdentifier identifier) {
+ public DOMStoreReadTransaction newReadOnlyTransaction(final TransactionIdentifier identifier) {
return super.newReadOnlyTransaction(identifier);
}
@Override
- public DOMStoreReadWriteTransaction newReadWriteTransaction(TransactionIdentifier identifier) {
+ public DOMStoreReadWriteTransaction newReadWriteTransaction(final TransactionIdentifier identifier) {
return super.newReadWriteTransaction(identifier);
}
@Override
- public DOMStoreWriteTransaction newWriteOnlyTransaction(TransactionIdentifier identifier) {
+ public DOMStoreWriteTransaction newWriteOnlyTransaction(final TransactionIdentifier identifier) {
return super.newWriteOnlyTransaction(identifier);
}
@SuppressWarnings({"unchecked", "checkstyle:IllegalCatch"})
@Override
- public LocalThreePhaseCommitCohort onTransactionReady(@Nonnull DOMStoreWriteTransaction tx,
- @Nullable Exception operationError) {
- Preconditions.checkArgument(tx instanceof SnapshotBackedWriteTransaction);
+ public LocalThreePhaseCommitCohort onTransactionReady(final DOMStoreWriteTransaction tx,
+ final 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, Exception operationError) {
- super(parent.getActorContext(), leader, transaction, modification, operationError);
+ protected LocalChainThreePhaseCommitCohort(
+ final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
+ final DataTreeModification modification, final Exception operationError) {
+ super(parent.getActorUtils(), leader, transaction, modification, operationError);
}
- protected LocalChainThreePhaseCommitCohort(SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
- Exception operationError) {
- super(parent.getActorContext(), leader, transaction, operationError);
+ protected LocalChainThreePhaseCommitCohort(
+ final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction,
+ final Exception operationError) {
+ super(parent.getActorUtils(), leader, transaction, operationError);
}
@Override
- protected void transactionAborted(SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
+ protected void transactionAborted(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
onTransactionFailed(transaction, ABORTED);
}
@Override
- protected void transactionCommitted(SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
+ protected void transactionCommitted(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
onTransactionCommited(transaction);
}
}