X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDataTreeCohortActorTest.java;h=ae8dd51466b0978b980f467a6ad1ce03d0cb06be;hb=refs%2Fchanges%2F76%2F105476%2F6;hp=aaf02600278eb6b844c4d103521a02612da2b54d;hpb=8e1d3c4f9001fbc8a5d3d3bea57916c5099078b2;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorTest.java index aaf0260027..ae8dd51466 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorTest.java @@ -47,7 +47,7 @@ import org.opendaylight.mdsal.dom.api.DOMDataTreeCommitCohort; import org.opendaylight.yangtools.util.concurrent.FluentFutures; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.tree.api.DataValidationFailedException; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext; import scala.concurrent.Await; /** @@ -57,7 +57,7 @@ import scala.concurrent.Await; */ public class DataTreeCohortActorTest extends AbstractActorTest { private static final Collection CANDIDATES = new ArrayList<>(); - private static final SchemaContext MOCK_SCHEMA = mock(SchemaContext.class); + private static final EffectiveModelContext MOCK_SCHEMA = mock(EffectiveModelContext.class); private final TestActorFactory actorFactory = new TestActorFactory(getSystem()); private final DOMDataTreeCommitCohort mockCohort = mock(DOMDataTreeCommitCohort.class); private final PostCanCommitStep mockPostCanCommit = mock(PostCanCommitStep.class); @@ -114,7 +114,7 @@ public class DataTreeCohortActorTest extends AbstractActorTest { ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor()); doReturn(executeWithDelay(executor, mockPostCanCommit)) - .when(mockCohort).canCommit(any(Object.class), any(SchemaContext.class), anyCollection()); + .when(mockCohort).canCommit(any(Object.class), any(EffectiveModelContext.class), anyCollection()); doReturn(executor.submit(() -> mockPostPreCommit)).when(mockPostCanCommit).preCommit(); @@ -140,7 +140,7 @@ public class DataTreeCohortActorTest extends AbstractActorTest { DataValidationFailedException failure = new DataValidationFailedException(YangInstanceIdentifier.empty(), "mock"); doReturn(FluentFutures.immediateFailedFluentFuture(failure)).when(mockCohort).canCommit(any(Object.class), - any(SchemaContext.class), anyCollection()); + any(EffectiveModelContext.class), anyCollection()); ActorRef cohortActor = newCohortActor("testFailureOnCanCommit"); @@ -203,7 +203,7 @@ public class DataTreeCohortActorTest extends AbstractActorTest { doReturn(ThreePhaseCommitStep.NOOP_ABORT_FUTURE).when(mockPostCanCommit).abort(); doReturn(Futures.immediateFuture(mockPostPreCommit)).when(mockPostCanCommit).preCommit(); doReturn(FluentFutures.immediateFluentFuture(mockPostCanCommit)).when(mockCohort).canCommit(any(Object.class), - any(SchemaContext.class), anyCollection()); + any(EffectiveModelContext.class), anyCollection()); doReturn(ThreePhaseCommitStep.NOOP_ABORT_FUTURE).when(mockPostPreCommit).abort(); doReturn(Futures.immediateFuture(null)).when(mockPostPreCommit).commit();