Skip to content

Commit 7bad8ae

Browse files
authored
Fixed concurrency crash (#554)
1 parent 31d22dc commit 7bad8ae

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Sources/OpenTelemetrySdk/Metrics/Stable/State/SynchronousMetricStorage.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public class SynchronousMetricStorage: SynchronousMetricStorageProtocol {
2020
var aggregatorHandles = [[String: AttributeValue]: AggregatorHandle]()
2121
let attributeProcessor: AttributeProcessor
2222
var aggregatorHandlePool = [AggregatorHandle]()
23-
private let aggregatorHandlesQueue = DispatchQueue(label: "org.opentelemetry.SynchronousMetricStorage.aggregatorHandlesQueue", attributes: .concurrent)
23+
private let aggregatorHandlesQueue = DispatchQueue(label: "org.opentelemetry.SynchronousMetricStorage.aggregatorHandlesQueue")
2424

2525

2626
static func empty() -> SynchronousMetricStorageProtocol {
@@ -76,7 +76,7 @@ public class SynchronousMetricStorage: SynchronousMetricStorageProtocol {
7676

7777
var points = [PointData]()
7878

79-
aggregatorHandlesQueue.sync(flags: .barrier) {
79+
aggregatorHandlesQueue.sync {
8080
aggregatorHandles.forEach { key, value in
8181
let point = value.aggregateThenMaybeReset(startEpochNano: start, endEpochNano: epochNanos, attributes: key, reset: reset)
8282
if reset {

0 commit comments

Comments
 (0)