Skip to content

Commit

Permalink
fix rebase bugs
Browse files Browse the repository at this point in the history
  • Loading branch information
hughsimpson committed Oct 10, 2023
1 parent 4ad2679 commit 1f2e11e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ object AkkaClusterShardingMetrics {
private val _shardTelemetryMap = TrieMap.empty[String, ShardTelemetry]

private def shardTelemetry(system: String, typeName: String, shardEntities: Histogram, shardMessages: Histogram): ShardTelemetry = {
_shardTelemetryMap.getOrElseUpdate(shardTelemetryKey(system, typeName), {
_shardTelemetryMap.atomicGetOrElseUpdate(shardTelemetryKey(system, typeName), {
val entitiesPerShard = TrieMap.empty[String, AtomicLong]
val messagesPerShard = TrieMap.empty[String, AtomicLong]
val samplingInterval = AkkaRemoteInstrumentation.settings().shardMetricsSampleInterval
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ object PekkoClusterShardingMetrics {
private val _shardTelemetryMap = TrieMap.empty[String, ShardTelemetry]

private def shardTelemetry(system: String, typeName: String, shardEntities: Histogram, shardMessages: Histogram): ShardTelemetry = {
_shardTelemetryMap.getOrElseUpdate(shardTelemetryKey(system, typeName), {
_shardTelemetryMap.atomicGetOrElseUpdate(shardTelemetryKey(system, typeName), {
val entitiesPerShard = TrieMap.empty[String, AtomicLong]
val messagesPerShard = TrieMap.empty[String, AtomicLong]
val samplingInterval = PekkoRemoteInstrumentation.settings().shardMetricsSampleInterval
Expand Down

0 comments on commit 1f2e11e

Please sign in to comment.