X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fprograms%2Fappendentries%2FClient.java;h=a3041e89dbf9ac2a9139552c6cafff7437bc0390;hp=2671be80bb93738b34ea0832a04fea3dfcf4c9db;hb=0230f37066dfd974accaf36bc712d6f1e60637d0;hpb=83641e25fafcabef7d64909b881a9a4b4b4dab87 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/programs/appendentries/Client.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/programs/appendentries/Client.java index 2671be80bb..a3041e89db 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/programs/appendentries/Client.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/programs/appendentries/Client.java @@ -13,19 +13,18 @@ import akka.actor.ActorSystem; import akka.actor.Props; import akka.actor.UntypedActor; import com.typesafe.config.ConfigFactory; -import org.opendaylight.controller.cluster.datastore.CompositeModificationPayload; +import java.util.ArrayList; +import java.util.List; import org.opendaylight.controller.cluster.datastore.modification.MutableCompositeModification; import org.opendaylight.controller.cluster.datastore.modification.WriteModification; import org.opendaylight.controller.cluster.example.messages.KeyValue; import org.opendaylight.controller.cluster.raft.ReplicatedLogEntry; import org.opendaylight.controller.cluster.raft.messages.AppendEntries; +import org.opendaylight.controller.cluster.raft.protobuff.client.messages.CompositeModificationPayload; import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload; import org.opendaylight.controller.md.cluster.datastore.model.TestModel; import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes; -import java.util.ArrayList; -import java.util.List; - public class Client { private static ActorSystem actorSystem; @@ -93,6 +92,11 @@ public class Client { @Override public long getIndex() { return 1; } + + @Override + public int size() { + return getData().size(); + } }); return new AppendEntries(1, "member-1", 0, 100, modification, 1); @@ -113,6 +117,11 @@ public class Client { @Override public long getIndex() { return 1; } + + @Override + public int size() { + return getData().size(); + } }); return new AppendEntries(1, "member-1", 0, 100, modification, 1);