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%2Fshardmanager%2FShardInformation.java;h=ea882dcbdf03ad3f26a3a90ab73f2d2d719e09af;hp=8ebb7e0cc9bfa7e83b2b5e72e9c3003631687070;hb=5b97f0fb5068bb3eb9b77b4509164707c5f35cd6;hpb=e2b581876b6ca70033affe321e07267dd7170705 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardInformation.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardInformation.java index 8ebb7e0cc9..ea882dcbdf 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardInformation.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardInformation.java @@ -21,13 +21,10 @@ import java.util.Objects; import java.util.Optional; import java.util.Set; import org.eclipse.jdt.annotation.Nullable; -import org.opendaylight.controller.cluster.access.concepts.MemberName; import org.opendaylight.controller.cluster.datastore.DatastoreContext; import org.opendaylight.controller.cluster.datastore.Shard; import org.opendaylight.controller.cluster.datastore.identifiers.ShardIdentifier; import org.opendaylight.controller.cluster.datastore.messages.PeerAddressResolved; -import org.opendaylight.controller.cluster.datastore.messages.PeerDown; -import org.opendaylight.controller.cluster.datastore.messages.PeerUp; import org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.OnShardInitialized; import org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.OnShardReady; import org.opendaylight.controller.cluster.raft.RaftState; @@ -136,18 +133,6 @@ public final class ShardInformation { notifyOnShardInitializedCallbacks(); } - void peerDown(final MemberName memberName, final String peerId, final ActorRef sender) { - if (actor != null) { - actor.tell(new PeerDown(memberName, peerId), sender); - } - } - - void peerUp(final MemberName memberName, final String peerId, final ActorRef sender) { - if (actor != null) { - actor.tell(new PeerUp(memberName, peerId), sender); - } - } - boolean isShardReady() { return !RaftState.Candidate.name().equals(role) && !Strings.isNullOrEmpty(role); }