more tests

Author: fandreuz

sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorageTest.java

@@ -521,6 +521,42 @@ void disableDropsAggregatorState(MemoryMode memoryMode) {
             sum ->
                 sum.satisfies(
                     sumData ->
-                        assertThat(sumData.getPoints()).allMatch(point -> point.getValue() == 5d)));
+                        assertThat(sumData.getPoints()).allMatch(point -> point.getValue() == 5)));
+  }
+
+  @ParameterizedTest
+  @EnumSource(MemoryMode.class)
+  void collect_DeltaResetAfterDisabled(MemoryMode memoryMode) {
+    setup(memoryMode);
+
+    when(reader.getAggregationTemporality(any())).thenReturn(AggregationTemporality.DELTA);
+    longCounterStorage =
+        AsynchronousMetricStorage.create(
+            registeredReader,
+            registeredView,
+            InstrumentDescriptor.create(
+                "long-counter",
+                "description",
+                "unit",
+                InstrumentType.COUNTER,
+                InstrumentValueType.LONG,
+                Advice.empty()));
+
+    longCounterStorage.setEpochInformation(0, 10);
+    longCounterStorage.record(Attributes.empty(), 5);
+    longCounterStorage.collect(resource, scope, 0, 0);
+
+    longCounterStorage.setEnabled(false);
+    longCounterStorage.setEnabled(true);
+
+    longCounterStorage.setEpochInformation(0, 30);
+    longCounterStorage.record(Attributes.empty(), 4);
+    MetricData metricData = longCounterStorage.collect(resource, scope, 0, 0);
+    assertThat(metricData)
+        .hasLongSumSatisfying(
+            sum ->
+                sum.satisfies(
+                    sumData ->
+                        assertThat(sumData.getPoints()).allMatch(point -> point.getValue() == 4)));
   }
 }

sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/state/SynchronousMetricStorageTest.java

@@ -922,4 +922,30 @@ void disableDropsAggregatorState(MemoryMode memoryMode) {
                     sumData ->
                         assertThat(sumData.getPoints()).allMatch(point -> point.getValue() == 5d)));
   }
+
+  @ParameterizedTest
+  @EnumSource(MemoryMode.class)
+  void collect_DeltaResetAfterDisabled(MemoryMode memoryMode) {
+    initialize(memoryMode);
+
+    DefaultSynchronousMetricStorage<?, ?> storage =
+        new DefaultSynchronousMetricStorage<>(
+            deltaReader, METRIC_DESCRIPTOR, aggregator, attributesProcessor, CARDINALITY_LIMIT);
+
+    storage.recordDouble(5d, Attributes.empty(), Context.current());
+    storage.collect(RESOURCE, INSTRUMENTATION_SCOPE_INFO, 0, 10);
+    deltaReader.setLastCollectEpochNanos(10);
+
+    storage.setEnabled(false);
+    storage.setEnabled(true);
+
+    storage.recordDouble(4d, Attributes.empty(), Context.current());
+    MetricData metricData = storage.collect(RESOURCE, INSTRUMENTATION_SCOPE_INFO, 0, 30);
+    assertThat(metricData)
+        .hasDoubleSumSatisfying(
+            sum ->
+                sum.satisfies(
+                    sumData ->
+                        assertThat(sumData.getPoints()).allMatch(point -> point.getValue() == 4d)));
+  }
 }