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=a68a0a80d1a56748156f23fe1fa1a8c07eac3e40;hb=7204c455a1636a7fc89bcd28fe9e9000eaa81b3b;hp=5357e6900a152b36bf441bc7be78e97fc4eb9a9e;hpb=5c5c980e564d2b5f6cd26821ffd26997f59af260;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 5357e6900a..a68a0a80d1 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 @@ -35,6 +35,67 @@ bounded-mailbox { mailbox-push-timeout-time = 100ms } +test { + 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" + } + + akka { + persistence.snapshot-store.plugin = "in-memory-snapshot-store" + persistence.journal.plugin = "in-memory-journal" + + loglevel = "INFO" + + actor { + 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 + } + } + 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" @@ -54,12 +115,12 @@ Member1 { akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" - - loglevel = "DEBUG" - + + loglevel = "INFO" + actor { provider = "akka.cluster.ClusterActorRefProvider" - + serializers { java = "akka.serialization.JavaSerializer" proto = "akka.remote.serialization.ProtobufSerializer" @@ -73,6 +134,12 @@ Member1 { } 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,8 +147,8 @@ Member1 { } cluster { - auto-down-unreachable-after = 100s - + retry-unsuccessful-join-after = 100ms + roles = [ "member-1" ] @@ -95,7 +162,7 @@ Member2 { mailbox-capacity = 1000 mailbox-push-timeout-time = 100ms } - + in-memory-journal { class = "org.opendaylight.controller.cluster.raft.utils.InMemoryJournal" } @@ -104,14 +171,14 @@ Member2 { class = "org.opendaylight.controller.cluster.raft.utils.InMemorySnapshotStore" plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher" } - + akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" - + actor { provider = "akka.cluster.ClusterActorRefProvider" - + serializers { java = "akka.serialization.JavaSerializer" proto = "akka.remote.serialization.ProtobufSerializer" @@ -125,6 +192,12 @@ Member2 { } 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 @@ -132,8 +205,8 @@ Member2 { } cluster { - auto-down-unreachable-after = 100s - + retry-unsuccessful-join-after = 100ms + roles = [ "member-2" ] @@ -160,12 +233,12 @@ Member3 { akka { persistence.snapshot-store.plugin = "in-memory-snapshot-store" persistence.journal.plugin = "in-memory-journal" - - loglevel = "DEBUG" - + + loglevel = "INFO" + actor { provider = "akka.cluster.ClusterActorRefProvider" - + serializers { java = "akka.serialization.JavaSerializer" proto = "akka.remote.serialization.ProtobufSerializer" @@ -179,6 +252,12 @@ Member3 { } 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 @@ -186,11 +265,151 @@ Member3 { } cluster { - auto-down-unreachable-after = 100s - + retry-unsuccessful-join-after = 100ms + roles = [ "member-3" ] } } } + +Member4 { + 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" + } + + akka { + persistence.snapshot-store.plugin = "in-memory-snapshot-store" + persistence.journal.plugin = "in-memory-journal" + + loglevel = "INFO" + + actor { + 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 + } + } + 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 + } + } + + cluster { + retry-unsuccessful-join-after = 100ms + + roles = [ + "member-4" + ] + } + } +} + +Member5 { + 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" + } + + akka { + persistence.snapshot-store.plugin = "in-memory-snapshot-store" + persistence.journal.plugin = "in-memory-journal" + + loglevel = "INFO" + + actor { + 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 + } + } + 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 + } + } + + cluster { + retry-unsuccessful-join-after = 100ms + + roles = [ + "member-5" + ] + } + } +} + +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 +}