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%2FDatastoreSnapshotRestoreTest.java;h=5cefc8b36d76b91dc4c3731cda8be398374ddfa5;hb=1413d39efa41e0b3926e400dbd7ef5e3fac694c2;hp=e9b4a75839f30f90275cfd48385a57094ee757f9;hpb=66e553f2098ea61426c4a441be57395673535c2f;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DatastoreSnapshotRestoreTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DatastoreSnapshotRestoreTest.java index e9b4a75839..5cefc8b36d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DatastoreSnapshotRestoreTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DatastoreSnapshotRestoreTest.java @@ -15,9 +15,9 @@ import static org.junit.Assert.assertTrue; import java.io.File; import java.io.FileOutputStream; -import java.math.BigInteger; import java.util.Arrays; import java.util.Collections; +import java.util.Optional; import org.apache.commons.lang3.SerializationUtils; import org.junit.After; import org.junit.Test; @@ -32,6 +32,7 @@ import org.opendaylight.controller.md.cluster.datastore.model.CarsModel; import org.opendaylight.controller.md.cluster.datastore.model.PeopleModel; import org.opendaylight.controller.md.cluster.datastore.model.SchemaContextHelper; import org.opendaylight.controller.md.cluster.datastore.model.TestModel; +import org.opendaylight.yangtools.yang.common.Uint64; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree; @@ -63,8 +64,7 @@ public class DatastoreSnapshotRestoreTest { newShardManagerSnapshot("config-one", "config-two"), Arrays.asList(new DatastoreSnapshot.ShardSnapshot("config-one", newSnapshot(CarsModel.BASE_PATH, CarsModel.newCarsNode(CarsModel.newCarsMapNode(CarsModel.newCarEntry("optima", - BigInteger.valueOf(20000L)),CarsModel.newCarEntry("sportage", - BigInteger.valueOf(30000L)))))), + Uint64.valueOf(20000)),CarsModel.newCarEntry("sportage", Uint64.valueOf(30000)))))), new DatastoreSnapshot.ShardSnapshot("config-two", newSnapshot(PeopleModel.BASE_PATH, PeopleModel.emptyContainer())))); @@ -78,18 +78,15 @@ public class DatastoreSnapshotRestoreTest { SerializationUtils.serialize(snapshotList, fos); } - DatastoreSnapshotRestore instance = DatastoreSnapshotRestore.instance(restoreDirectoryPath); + DefaultDatastoreSnapshotRestore instance = new DefaultDatastoreSnapshotRestore(restoreDirectoryPath); + instance.activate(); - assertDatastoreSnapshotEquals(configSnapshot, instance.getAndRemove("config")); - assertDatastoreSnapshotEquals(operSnapshot, instance.getAndRemove("oper")); + assertDatastoreSnapshotEquals(configSnapshot, instance.getAndRemove("config").orElse(null)); + assertDatastoreSnapshotEquals(operSnapshot, instance.getAndRemove("oper").orElse(null)); - assertNull("DatastoreSnapshot was not removed", instance.getAndRemove("config")); + assertEquals("DatastoreSnapshot was not removed", Optional.empty(), instance.getAndRemove("config")); assertFalse(backupFile + " was not deleted", backupFile.exists()); - - instance = DatastoreSnapshotRestore.instance(restoreDirectoryPath); - assertNull("Expected null DatastoreSnapshot", instance.getAndRemove("config")); - assertNull("Expected null DatastoreSnapshot", instance.getAndRemove("oper")); } private static void assertDatastoreSnapshotEquals(final DatastoreSnapshot expected,