X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-config%2Fsrc%2Fmain%2Fresources%2Finitial%2Ffactory-akka.conf;h=3296e0574cb2e47435a52cdba3206d51d1d96ef8;hp=ad18d436118db4e1d69ad570bbcd85ca4341c3ef;hb=a3459dc797e4e0722b945b80bc8ef3123762fc8d;hpb=51bf6c7493843ad23f074930b56925162732a8b2 diff --git a/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/factory-akka.conf b/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/factory-akka.conf index ad18d43611..3296e0574c 100644 --- a/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/factory-akka.conf +++ b/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/factory-akka.conf @@ -28,6 +28,20 @@ odl-cluster-data { throughput = 1 } + serialization-dispatcher { + type = Dispatcher + executor = "fork-join-executor" + fork-join-executor { + # Min number of threads to cap factor-based parallelism number to + parallelism-min = 2 + # Parallelism (threads) ... ceil(available processors * factor) + parallelism-factor = 2.0 + # Max number of threads to cap factor-based parallelism number to + parallelism-max = 15 + } + throughput = 1 + } + shard-dispatcher { type = Dispatcher executor = "default-executor" @@ -49,11 +63,13 @@ odl-cluster-data { java = "akka.serialization.JavaSerializer" proto = "akka.remote.serialization.ProtobufSerializer" readylocal = "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransactionSerializer" + simpleReplicatedLogEntry = "org.opendaylight.controller.cluster.raft.persisted.SimpleReplicatedLogEntrySerializer" } serialization-bindings { "com.google.protobuf.Message" = proto "org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction" = readylocal + "org.opendaylight.controller.cluster.raft.persisted.SimpleReplicatedLogEntry" = simpleReplicatedLogEntry } default-dispatcher { @@ -70,6 +86,9 @@ odl-cluster-data { } remote { log-remote-lifecycle-events = off + # Disable passive connections, as we are seeing issues + # with read-only associations + use-passive-connections = off netty.tcp { maximum-frame-size = 419430400 @@ -79,19 +98,19 @@ odl-cluster-data { artery { advanced { - maximum-frame-size = 1 GiB - maximum-large-frame-size = 1 GiB + #maximum-frame-size = 256 KiB + #maximum-large-frame-size = 2 MiB } } } cluster { seed-node-timeout = 12s - + # Following is an excerpt from Akka Cluster Documentation # link - http://doc.akka.io/docs/akka/snapshot/java/cluster-usage.html # Warning - Akka recommends against using the auto-down feature of Akka Cluster in production. - # This is crucial for correct behavior if you use Cluster Singleton or Cluster Sharding, + # This is crucial for correct behavior if you use Cluster Singleton or Cluster Sharding, # especially together with Akka Persistence. #auto-down-unreachable-after = 30s @@ -104,7 +123,44 @@ odl-cluster-data { } persistence { - journal.plugin = akka.persistence.journal.leveldb + journal { + # The following activates the default segmented file journal. Each persistent actor + # is stored in a separate directory, with multiple segment files. Segments are removed + # when they are no longer required. + # + plugin = akka.persistence.journal.segmented-file + + segmented-file { + class = "org.opendaylight.controller.akka.segjournal.SegmentedFileJournal" + # Root directory for segmented journal storage + root-directory = "segmented-journal" + # Maximum size of a single entry in the segmented journal + max-entry-size = 16M + # Maximum size of a segment + max-segment-size = 128M + # Map each segment into memory. Note that while this can improve performance, + # it will also place additional burden on system resources. + memory-mapped = false + } + } + + # Journal configuration for shards that have persistence turned off. They still need to have a journal plugin + # configured, since they still need to store things in the journal occasionally, but having larger segment sizes + # would be wastefull. + non-persistent { + journal { + class = "org.opendaylight.controller.akka.segjournal.SegmentedFileJournal" + # Root directory for segmented journal storage + root-directory = "segmented-journal" + # Maximum size of a single entry in the segmented journal + max-entry-size = 512K + # Maximum size of a segment + max-segment-size = 1M + # Map each segment into memory. Note that while this can improve performance, + # it will also place additional burden on system resources. + memory-mapped = false + } + } snapshot-store.local.class = "org.opendaylight.controller.cluster.persistence.LocalSnapshotStore" snapshot-store.plugin = akka.persistence.snapshot-store.local