X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fpersisted%2FShardManagerSnapshot.java;h=728dd29ea3232c081dc0f5f0930f7185c514f287;hp=0bacbd0dbc03a9873215eeb5e85708bc6bdb6497;hb=dcc776a5e749d495a66e8753e123a1ddbd15d9c6;hpb=127042ea7e148d9dc0282acc3780b4754ca69e12 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/ShardManagerSnapshot.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/ShardManagerSnapshot.java index 0bacbd0dbc..728dd29ea3 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/ShardManagerSnapshot.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/ShardManagerSnapshot.java @@ -8,19 +8,14 @@ package org.opendaylight.controller.cluster.datastore.persisted; import com.google.common.collect.ImmutableList; -import com.google.common.collect.ImmutableMap; import java.io.Externalizable; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import java.io.Serializable; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; -import java.util.Map; import org.eclipse.jdt.annotation.NonNull; -import org.opendaylight.controller.cluster.datastore.config.PrefixShardConfiguration; -import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier; /** * Represents the persisted snapshot state for the ShardManager. @@ -52,12 +47,6 @@ public class ShardManagerSnapshot implements Serializable { for (String shard: snapshot.shardList) { out.writeObject(shard); } - - out.writeInt(snapshot.prefixShardConfiguration.size()); - for (Map.Entry prefixShardConfigEntry : snapshot.prefixShardConfiguration.entrySet()) { - out.writeObject(prefixShardConfigEntry.getKey()); - out.writeObject(prefixShardConfigEntry.getValue()); - } } @Override @@ -68,14 +57,7 @@ public class ShardManagerSnapshot implements Serializable { localShardList.add((String) in.readObject()); } - size = in.readInt(); - Map localPrefixShardConfiguration = new HashMap<>(size); - for (int i = 0; i < size; i++) { - localPrefixShardConfiguration.put((DOMDataTreeIdentifier) in.readObject(), - (PrefixShardConfiguration) in.readObject()); - } - - snapshot = new ShardManagerSnapshot(localShardList, localPrefixShardConfiguration); + snapshot = new ShardManagerSnapshot(localShardList); } private Object readResolve() { @@ -84,12 +66,9 @@ public class ShardManagerSnapshot implements Serializable { } private final List shardList; - private final Map prefixShardConfiguration; - public ShardManagerSnapshot(final @NonNull List shardList, - final Map prefixShardConfiguration) { + public ShardManagerSnapshot(final @NonNull List shardList) { this.shardList = ImmutableList.copyOf(shardList); - this.prefixShardConfiguration = ImmutableMap.copyOf(prefixShardConfiguration); } public List getShardList() {