raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #28568 from akka/wip-sharding-lmdb-patriknw

Browse source 
Don't initialize Lmdb when rememberEntities not used, #28567
This commit is contained in:
Patrik Nordwall 2020-02-11 08:48:46 +01:00 • committed by GitHub
commit 6120b73918
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

18
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ClusterSharding.scala
View file

@ -695,8 +695,6 @@ private[akka] class ClusterShardingGuardian extends Actor {
val sharding = ClusterSharding(context.system)
val majorityMinCap = context.system.settings.config.getInt("akka.cluster.sharding.distributed-data.majority-min-cap")
private lazy val replicatorSettings =
ReplicatorSettings(context.system.settings.config.getConfig("akka.cluster.sharding.distributed-data"))
private var replicatorByRole = Map.empty[Option[String], ActorRef]
private def coordinatorSingletonManagerName(encName: String): String =
@ -705,6 +703,18 @@ private[akka] class ClusterShardingGuardian extends Actor {
private def coordinatorPath(encName: String): String =
(self.path / coordinatorSingletonManagerName(encName) / "singleton" / "coordinator").toStringWithoutAddress
private def replicatorSettings(shardingSettings: ClusterShardingSettings) = {
val configuredSettings =
ReplicatorSettings(context.system.settings.config.getConfig("akka.cluster.sharding.distributed-data"))
// Use members within the data center and with the given role (if any)
val replicatorRoles = Set(ClusterSettings.DcRolePrefix + cluster.settings.SelfDataCenter) ++ shardingSettings.role
val settingsWithRoles = configuredSettings.withRoles(replicatorRoles)
if (shardingSettings.rememberEntities)
settingsWithRoles
else
settingsWithRoles.withDurableKeys(Set.empty[String])
}
private def replicator(settings: ClusterShardingSettings): ActorRef = {
if (settings.stateStoreMode == ClusterShardingSettings.StateStoreModeDData) {
// one Replicator per role
@ -715,9 +725,7 @@ private[akka] class ClusterShardingGuardian extends Actor {
case Some(r) => URLEncoder.encode(r, ByteString.UTF_8) + "Replicator"
case None => "replicator"
}
// Use members within the data center and with the given role (if any)
val replicatorRoles = Set(ClusterSettings.DcRolePrefix + cluster.settings.SelfDataCenter) ++ settings.role
val ref = context.actorOf(Replicator.props(replicatorSettings.withRoles(replicatorRoles)), name)
val ref = context.actorOf(Replicator.props(replicatorSettings(settings)), name)
replicatorByRole = replicatorByRole.updated(settings.role, ref)
ref
}