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%2FShardRecoveryCoordinatorTest.java;h=31026fd79ff273626a6bf6dc0a6af6af49eef0e1;hb=refs%2Fchanges%2F62%2F95162%2F17;hp=0b78e3244d588fc3c7b0ec1b8072e908b0a56f12;hpb=66e553f2098ea61426c4a441be57395673535c2f;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardRecoveryCoordinatorTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardRecoveryCoordinatorTest.java index 0b78e3244d..31026fd79f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardRecoveryCoordinatorTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardRecoveryCoordinatorTest.java @@ -29,10 +29,11 @@ import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeConfiguration; 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.DataValidationFailedException; import org.opendaylight.yangtools.yang.data.api.schema.tree.TreeType; import org.opendaylight.yangtools.yang.data.impl.schema.tree.InMemoryDataTreeFactory; import org.opendaylight.yangtools.yang.data.impl.schema.tree.SchemaValidationFailedException; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -40,8 +41,8 @@ public class ShardRecoveryCoordinatorTest extends AbstractTest { private static final Logger FOO_LOGGER = LoggerFactory.getLogger("foo"); private ShardDataTree peopleDataTree; - private SchemaContext peopleSchemaContext; - private SchemaContext carsSchemaContext; + private EffectiveModelContext peopleSchemaContext; + private EffectiveModelContext carsSchemaContext; private ShardRecoveryCoordinator coordinator; @Before @@ -57,7 +58,8 @@ public class ShardRecoveryCoordinatorTest extends AbstractTest { } @Test - public void testAppendRecoveredLogEntryCommitTransactionPayload() throws IOException { + public void testAppendRecoveredLogEntryCommitTransactionPayload() throws IOException, + DataValidationFailedException { try { coordinator.appendRecoveredLogEntry(CommitTransactionPayload.create(nextTransactionId(), createCar())); } catch (final SchemaValidationFailedException e) { @@ -68,7 +70,7 @@ public class ShardRecoveryCoordinatorTest extends AbstractTest { } @Test - public void testApplyRecoverySnapshot() { + public void testApplyRecoverySnapshot() throws DataValidationFailedException { coordinator.applyRecoverySnapshot(createSnapshot()); assertFalse(readCars(peopleDataTree).isPresent()); @@ -85,7 +87,7 @@ public class ShardRecoveryCoordinatorTest extends AbstractTest { } } - private DataTreeCandidate createCar() { + private DataTreeCandidate createCar() throws DataValidationFailedException { final DataTree dataTree = new InMemoryDataTreeFactory().create( DataTreeConfiguration.DEFAULT_OPERATIONAL, carsSchemaContext); @@ -98,23 +100,23 @@ public class ShardRecoveryCoordinatorTest extends AbstractTest { return dataTree.prepare(modification); } - private Optional> readCars(final ShardDataTree shardDataTree) { + private Optional readCars(final ShardDataTree shardDataTree) { final DataTree dataTree = shardDataTree.getDataTree(); // FIXME: this should not be called here - dataTree.setSchemaContext(peopleSchemaContext); + dataTree.setEffectiveModelContext(peopleSchemaContext); return shardDataTree.readNode(CarsModel.BASE_PATH); } - private Optional> readPeople(final ShardDataTree shardDataTree) { + private Optional readPeople(final ShardDataTree shardDataTree) { final DataTree dataTree = shardDataTree.getDataTree(); // FIXME: this should not be called here - dataTree.setSchemaContext(peopleSchemaContext); + dataTree.setEffectiveModelContext(peopleSchemaContext); return shardDataTree.readNode(PeopleModel.BASE_PATH); } - private static ShardSnapshotState createSnapshot() { + private static ShardSnapshotState createSnapshot() throws DataValidationFailedException { final DataTree dataTree = new InMemoryDataTreeFactory().create( DataTreeConfiguration.DEFAULT_OPERATIONAL, SchemaContextHelper.select(SchemaContextHelper.CARS_YANG, SchemaContextHelper.PEOPLE_YANG));