X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fresources%2Fapplication.conf;h=abefdf0ce94006297264a7ed25d126240a7514b4;hb=987e2e706d0b343304142626bc870f3e8c909b51;hp=f0cf18932f11f3acb07598065715c2fbdf6b1b01;hpb=c7846405c83f680660852f299d8051b420b3cddd;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/resources/application.conf b/opendaylight/md-sal/sal-distributed-datastore/src/test/resources/application.conf index f0cf18932f..abefdf0ce9 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/resources/application.conf +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/resources/application.conf @@ -5,16 +5,7 @@ akka { loggers = ["akka.testkit.TestEventListener", "akka.event.slf4j.Slf4jLogger"] actor { - serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" - } - - serialization-bindings { - "org.opendaylight.controller.cluster.datastore.modification.MutableCompositeModification" = java - "com.google.protobuf.Message" = proto - - } + warn-about-java-serializer-usage = false } } @@ -35,6 +26,72 @@ bounded-mailbox { mailbox-push-timeout-time = 100ms } +test-config { + bounded-mailbox { + mailbox-type = "org.opendaylight.controller.cluster.common.actor.MeteredBoundedMailbox" + mailbox-capacity = 1000 + mailbox-push-timeout-time = 100ms + } + + in-memory-journal { + class = "org.opendaylight.controller.cluster.raft.utils.InMemoryJournal" + } + + in-memory-snapshot-store { + class = "org.opendaylight.controller.cluster.raft.utils.InMemorySnapshotStore" + plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" + } + + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + + akka { + persistence.snapshot-store.plugin = "in-memory-snapshot-store" + persistence.journal.plugin = "in-memory-journal" + + loglevel = "INFO" + + actor { + provider = "akka.cluster.ClusterActorRefProvider" + + serializers { + readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" + } + + serialization-bindings { + "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal + } + + warn-about-java-serializer-usage = false + } + remote { + log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2565 + } + + netty.tcp { + hostname = "127.0.0.1" + port = 2565 + } + } + + cluster { + auto-down-unreachable-after = 100s + retry-unsuccessful-join-after = 100ms + + roles = [ + "member-1" + ] + } + } +} + Member1 { bounded-mailbox { mailbox-type = "org.opendaylight.controller.cluster.common.actor.MeteredBoundedMailbox" @@ -51,6 +108,12 @@ Member1 { plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" @@ -61,18 +124,23 @@ Member1 { provider = "akka.cluster.ClusterActorRefProvider" serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" } serialization-bindings { - "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal } + + warn-about-java-serializer-usage = false } remote { log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2558 + } + netty.tcp { hostname = "127.0.0.1" port = 2558 @@ -80,7 +148,6 @@ Member1 { } cluster { - auto-down-unreachable-after = 100s retry-unsuccessful-join-after = 100ms roles = [ @@ -106,6 +173,12 @@ Member2 { plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" @@ -114,18 +187,23 @@ Member2 { provider = "akka.cluster.ClusterActorRefProvider" serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" } serialization-bindings { - "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal } + + warn-about-java-serializer-usage = false } remote { log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2559 + } + netty.tcp { hostname = "127.0.0.1" port = 2559 @@ -133,7 +211,6 @@ Member2 { } cluster { - auto-down-unreachable-after = 100s retry-unsuccessful-join-after = 100ms roles = [ @@ -159,6 +236,12 @@ Member3 { plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" @@ -169,18 +252,23 @@ Member3 { provider = "akka.cluster.ClusterActorRefProvider" serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" } serialization-bindings { - "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal } + + warn-about-java-serializer-usage = false } remote { log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2557 + } + netty.tcp { hostname = "127.0.0.1" port = 2557 @@ -188,7 +276,6 @@ Member3 { } cluster { - auto-down-unreachable-after = 100s retry-unsuccessful-join-after = 100ms roles = [ @@ -214,6 +301,12 @@ Member4 { plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" @@ -224,18 +317,23 @@ Member4 { provider = "akka.cluster.ClusterActorRefProvider" serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" } serialization-bindings { - "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal } + + warn-about-java-serializer-usage = false } remote { log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2560 + } + netty.tcp { hostname = "127.0.0.1" port = 2560 @@ -243,7 +341,6 @@ Member4 { } cluster { - auto-down-unreachable-after = 100s retry-unsuccessful-join-after = 100ms roles = [ @@ -269,6 +366,12 @@ Member5 { plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" @@ -279,18 +382,23 @@ Member5 { provider = "akka.cluster.ClusterActorRefProvider" serializers { - java = "akka.serialization.JavaSerializer" - proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" } serialization-bindings { - "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal } + + warn-about-java-serializer-usage = false } remote { log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2561 + } + netty.tcp { hostname = "127.0.0.1" port = 2561 @@ -298,7 +406,6 @@ Member5 { } cluster { - auto-down-unreachable-after = 100s retry-unsuccessful-join-after = 100ms roles = [ @@ -307,3 +414,88 @@ Member5 { } } } + +Member256 { + bounded-mailbox { + mailbox-type = "org.opendaylight.controller.cluster.common.actor.MeteredBoundedMailbox" + mailbox-capacity = 1000 + mailbox-push-timeout-time = 100ms + } + + in-memory-journal { + class = "org.opendaylight.controller.cluster.raft.utils.InMemoryJournal" + } + + in-memory-snapshot-store { + class = "org.opendaylight.controller.cluster.raft.utils.InMemorySnapshotStore" + plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" + } + + shard-dispatcher { + type = Dispatcher + executor = "default-executor" + mailbox-type = "org.opendaylight.controller.cluster.common.actor.UnboundedDequeBasedControlAwareMailbox" + } + + akka { + persistence.snapshot-store.plugin = "in-memory-snapshot-store" + persistence.journal.plugin = "in-memory-journal" + + loglevel = "INFO" + + actor { + provider = "akka.cluster.ClusterActorRefProvider" + + serializers { + readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" + } + + serialization-bindings { + "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal + } + + warn-about-java-serializer-usage = false + } + remote { + log-remote-lifecycle-events = off + artery { + enabled = on + canonical.hostname = "127.0.0.1" + canonical.port = 2562 + } + + netty.tcp { + hostname = "127.0.0.1" + port = 2562 + } + } + + cluster { + retry-unsuccessful-join-after = 100ms + + roles = [ + "member-256" + ] + } + } +} + +Member1-without-artery { + akka.remote.artery.enabled = off +} + +Member2-without-artery { + akka.remote.artery.enabled = off +} + +Member3-without-artery { + akka.remote.artery.enabled = off +} + +Member4-without-artery { + akka.remote.artery.enabled = off +} + +Member5-without-artery { + akka.remote.artery.enabled = off +}