Change remaining SnapshotSelectionCriteria to prioritize timestamp 47/83047/1
authorTomas Cere <tomas.cere@pantheon.tech>
Thu, 11 Jul 2019 10:19:47 +0000 (12:19 +0200)
committerRobert Varga <nite@hq.sk>
Mon, 15 Jul 2019 15:21:44 +0000 (15:21 +0000)
These are also needed and were missed in the original run-through.

Change-Id: Icede0673c580f793ffe81ccecf728c15dc6e83ca
Signed-off-by: Tomas Cere <tomas.cere@pantheon.tech>
(cherry picked from commit 2f606b3ee1b8e47977320374e37f3d5c1d546f9b)

opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/SavingClientActorBehavior.java
opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/BucketStoreActor.java

index 8f6e991519d045234bcc6a7a3ba7784a5b5bb1fc..58a10776f4b6723303c42eeae05024c841ad1f44 100644 (file)
@@ -39,7 +39,7 @@ final class SavingClientActorBehavior extends RecoveredClientActorBehavior<Initi
         } else if (command instanceof SaveSnapshotSuccess) {
             LOG.debug("{}: got command: {}", persistenceId(), command);
             SaveSnapshotSuccess saved = (SaveSnapshotSuccess)command;
-            context().deleteSnapshots(new SnapshotSelectionCriteria(saved.metadata().sequenceNr(),
+            context().deleteSnapshots(new SnapshotSelectionCriteria(scala.Long.MaxValue(),
                     saved.metadata().timestamp() - 1, 0L, 0L));
             return this;
         } else if (command instanceof DeleteSnapshotsSuccess) {
index 9a84b91300c7681515f8dd85a94475aab1fb1364..7d2cd4fabf45887a1f9f5ab0d1781ed458c9d1e7 100644 (file)
@@ -180,7 +180,7 @@ public abstract class BucketStoreActor<T extends BucketData<T>> extends
         } else if (message instanceof SaveSnapshotSuccess) {
             LOG.debug("{}: got command: {}", persistenceId(), message);
             SaveSnapshotSuccess saved = (SaveSnapshotSuccess)message;
-            deleteSnapshots(new SnapshotSelectionCriteria(saved.metadata().sequenceNr(),
+            deleteSnapshots(new SnapshotSelectionCriteria(scala.Long.MaxValue(),
                     saved.metadata().timestamp() - 1, 0L, 0L));
             persisting = false;
             unstash();